[ https://issues.apache.org/jira/browse/KAFKA-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma resolved KAFKA-3860. -------------------------------- Resolution: Auto Closed The old consumer is no longer supported, please upgrade to the Java consumer whenever possible. > No broker partitions consumed by consumer thread > ------------------------------------------------ > > Key: KAFKA-3860 > URL: https://issues.apache.org/jira/browse/KAFKA-3860 > Project: Kafka > Issue Type: Bug > Components: consumer > Affects Versions: 0.8.2.1 > Environment: centOS > Reporter: Kundan > Assignee: Neha Narkhede > > I'm using kakfa-clients-0.8.2.1 to consume messages as Java KafkaConsumer. > Problem: I have two consumer one consumer is able receive message message but > another consumer is unable to receive message and one of the WARNING was > visible in log saying that "No broker partitions consumed by consumer thread" > and also it was observed that offset was (-1)[selected partitions : > mytopic:0: fetched offset = -1: consumed offset = -1] while fetching offset > at consumer end. > Another log was "entering consume " which is kept > ZookeeperConsumerConnector.scala file at line 220. > Other information > 1) Environment: CentOS > 2) No of zookeper: 5, > 3) Properties used to connect zookeeper: > a)zookeeper.connect : zk1:2181,zk2:2181,zk2:2181,zk4:2181,zk5:2181, > b)group.id: mygroupId > c) fetch.message.max.bytes: 5242880 (Producer side also set) > d) auto.commit.enable: false > 4) Single thread Highlevel consumer code used to consume data. > 5) Consumer is running in separate VM Kafka/zookeeper in separate VM > -- This message was sent by Atlassian JIRA (v6.4.14#64029)