On 2/13/16 6:16 AM, Ismael Juma wrote:
> Hi Damian,
>
> KAFKA-2978, which would cause consumption to stop would happen after a
> consumer group rebalance. Was this the case for you?
>
> It would be great if you could upgrade the client to 0.9.0.1 RC1 in order
> to check if the problem still happens
I get the following test failures on both OSX (10.11.3) and Ubuntu
(14.04), JDK 1.7 and 1.8.
KafkaConsumerTest. testConstructorClose
KafkaProducerTest. testConstructorFailureCloseResource
SelectorTest. testNoRouteToHost
SslSelectorTest. testNoRouteToHost
All seem to be expecting exceptions that a
assigned partitions here
> }
> void onPartitionsRevoked(List partitions) {
> // commit offsets if you need to
> }
> });
>
> while (true) {
> ConsumerRecords records = consumer.poll(100);
> // do stuff with records
> }
>
> Does that make sense?
Yes, t
I have been experimenting with the KafkaConsumer currently in
development [1]. Sorry if this should be a question for the user
list, but I am not sure if what I am seeing is something not working
yet or if I am misunderstanding the API. If I use
KafkaConsumer#subscribe to subscribe to a topic and
Phil Steitz created KAFKA-2524:
--
Summary: Examples in class javadoc use unimplemented subscribe
method
Key: KAFKA-2524
URL: https://issues.apache.org/jira/browse/KAFKA-2524
Project: Kafka
