[
https://issues.apache.org/jira/browse/KAFKA-18686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922859#comment-17922859
]
Matthias J. Sax commented on KAFKA-18686:
-----------------------------------------
Could it pin it down further. The consumer's position does not advance and this
condition never becomes "true":
[https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java#L280]
So overall it seems, the consumer does not return data at all to the KS code
(or does return data, but gives back an incorrect `position`). Hope this helps.
> Flaky test
> StandbyTaskEOSMultiRebalanceIntegrationTest#shouldHonorEOSWhenUsingCachingAndStandbyReplicas
> -------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-18686
> URL: https://issues.apache.org/jira/browse/KAFKA-18686
> Project: Kafka
> Issue Type: Test
> Components: streams, unit tests
> Reporter: 黃竣陽
> Assignee: Matthias J. Sax
> Priority: Major
>
> It seens this test flaky these days
> [https://github.com/apache/kafka/actions/runs/13061784839/job/36451152058]
> [https://github.com/apache/kafka/actions/runs/13067934631/job/36463514470?pr=18763]
> https://github.com/apache/kafka/actions/runs/13068036157/job/36463989916?pr=18641
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
