Sergiu Hlihor created KAFKA-4571: ------------------------------------ Summary: Consumer fails to retrieve messages if started before producer Key: KAFKA-4571 URL: https://issues.apache.org/jira/browse/KAFKA-4571 Project: Kafka Issue Type: Bug Components: clients Affects Versions: 0.10.1.1 Environment: Ubuntu Desktop 16.04 LTS, Oracle Java 8 1.8.0_101, Core i7 4770K Reporter: Sergiu Hlihor
In a configuration where topic was never created before, starting the consumer before the producer leads to no message being consumed (KafkaConsumer.pool() returns always an instance of ConsumerRecords with 0 count ). Starting another consumer on the same group, same topic after messages were produced is still not consuming them. Starting another consumer with another groupId appears to be working. In the consumer logs I see: WARN NetworkClient - Error while fetching metadata with correlation id 1 : {measurements021=LEADER_NOT_AVAILABLE} Both producer and consumer were launched from inside same JVM. The configuration used is the standard one found in Kafka distribution. If this is a configuration issue, please suggest any change that I should do. Thank you -- This message was sent by Atlassian JIRA (v6.3.4#6332)