You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/12/02 01:44:00 UTC
[jira] [Commented] (KAFKA-13458) The Stream is not able to consume from some of the partitions
[ 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)