Hari created KAFKA-1708:
---------------------------
Summary: Consumers intermittently stop consuming till restart
Key: KAFKA-1708
URL: https://issues.apache.org/jira/browse/KAFKA-1708
Project: Kafka
Issue Type: Bug
Components: consumer
Affects Versions: 0.8.0
Environment: HP 40 x Intel(R) Xeon(R) CPU E5-2470 v2 @
2.40GHz/1.2e+02GB
Reporter: Hari
Assignee: Neha Narkhede
Using a simple consumer, and reading messages using StreamIterator noticed that
the consumptions suddenly stops and the lag starts building up till the
consumer is restarted. Below is the code snippet
final Map<String, List<KafkaStream<byte[], byte[]>>> streamsByName =
consumerConnector.createMessageStreams(topicCountMap);
ConsumerIterator<byte[], byte[]> streamIterator =
streamsByName.get(topicName).get(IDX_FIRST_ITEM).iterator();
if (streamIterator.hasNext()) {
final MessageAndMetadata<byte[], byte[]> item =
streamIterator.next();
...
}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
