Kundan created KAFKA-3860:
-----------------------------
Summary: 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) 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.3.4#6332)
