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)