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)