[
https://issues.apache.org/jira/browse/KAFKA-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677456#comment-15677456
]
Guozhang Wang commented on KAFKA-4373:
--------------------------------------
This may be resulted from the intermediate topic that is written by topology 1
and read by topology 2 was truncated due to log retention policy. To validate,
could you check the streams client log and see if there are entries mentioning
"... is out of range for partition ..."
> Kafka Consumer API jumping offsets
> ----------------------------------
>
> Key: KAFKA-4373
> URL: https://issues.apache.org/jira/browse/KAFKA-4373
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Reporter: Srinivasan Venkatraman
>
> Hi,
> I am using Kafka Version 0.10.0.1 and java consumer API to consume messages
> from a topic. We are using a single node kafka and zookeeper. It is sometimes
> observed that the consumer is losing a bulk of message. We are unable to find
> the exact reason to replicate the issue.
> The scenario is:
> Consumer polls the topic.
> Fetches the messages and gives it to a thread pool to handle the message.
> Waits for the threads to return and then commits the offsets.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
