[ 
https://issues.apache.org/jira/browse/KAFKA-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446297#comment-17446297
 ] 

Darshan Marathe commented on KAFKA-13458:
-----------------------------------------

[~guozhang] Thanks, No we are not using any third-party client to stream 
messages.
I've read through the KAFKA-13375, it seems like a similar issue.
I want to point out one thing here, 
There are other consumers also who are consuming through the same topic but 
they use KafkaConsumer and they are able to consume it successfully.
if the issue is on the broker side why it's failing for KafkaStream only.

> 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)

Reply via email to