Possible bug: KafkaConsumer.endOffsets can return partial data

2018-05-04 Thread Fedor Bobin
Hello. When migrating to 1.1.0 I faced with changed behavior: KafkaConsumer.endOffsets can return partial data. As I see it was introduced with KAFKA-6397 (Consumer should not block setting initial positions of unavailable partitions). There is strange code at org.apache.kafka.clients.consumer.i

Possible bug: KafkaConsumer.endOffsets can return partial data

2018-05-03 Thread Fedor Bobin
Hello. When migrating to 1.1.0 I faced with changed behavior: KafkaConsumer.endOffsets can return partial data. As I see it was introduced with KAFKA-6397 (Consumer should not block setting initial positions of unavailable partitions). There is strange code at org.apache.kafka.clients.consumer.i