[ https://issues.apache.org/jira/browse/KAFKA-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452111#comment-17452111 ]
Matthias J. Sax commented on KAFKA-13458: ----------------------------------------- [~marathed] You are using the Java consumer directly? It the consumer configured in "read committed" mode? What about the other consumers you mentioned: are they also configure with "read committed" or default "read uncommitted"? > The Stream is not able to consume from some of the partitions > ------------------------------------------------------------- > > Key: KAFKA-13458 > URL: https://issues.apache.org/jira/browse/KAFKA-13458 > Project: Kafka > Issue Type: Bug > Reporter: Darshan Marathe > Priority: Blocker > > Hi Team > Kafka-stream version: 2.6.0 > some messages are stuck in the following partitions, and the stream is not > able to consume them from those partitions. > Restart the stream multiple times, but still issue is same. > Have faced the following issue, > The following partitions still have unstable offsets which are not cleared on > the broker side: [TASK_STREAM-29], this could be either transactional offsets > waiting for completion, or normal offsets waiting for replication after > appending to local log > The following partitions still have unstable offsets which are not cleared on > the broker side: [TASK_STREAM-0] > The following partitions still have unstable offsets which are not cleared on > the broker side: [TASK_STREAM-3] > The following partitions still have unstable offsets which are not cleared on > the broker side: [TASK_STREAM-9] > The following partitions still have unstable offsets which are not cleared on > the broker side: [TASK_STREAM-14] -- This message was sent by Atlassian Jira (v8.20.1#820001)