[
https://issues.apache.org/jira/browse/KAFKA-19442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987347#comment-17987347
]
Bruno Cadonna commented on KAFKA-19442:
---------------------------------------
Could you please upgrade your Kafka Streams library and come back to this
ticket if you encounter this error again? Ideally upgrade to something like
3.9.1 or newer.
It is very unlikely that we will provide another patch release for the 3.5
series. If you encounter the same error in 3.9.1 or higher, we need to do
something about it. With 3.5.1, the risk is simply too high that we try to fix
a bug that we have already fixed.
Best for you would be to find a way to reproduce the behavior and then test if
the faulty behavior persists a version upgrade of Kafka Streams.
> Kafka Streams state store used an outdated value when reducing records,
> resulting in incorrect output.
> ------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-19442
> URL: https://issues.apache.org/jira/browse/KAFKA-19442
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Reporter: juned
> Priority: Major
>
> We observed a case where a reduce operation used an older version of the
> store value instead of the latest when processing a new input.
> Below i am describing the sequence of input and its outcome in changelog and
> output topic
> Lets see currently there is a key,value pair M0, in changelog & output Topic.
> and u1,u2,u3 updates are received for the same key in the same order.
> For u1,u2 all are fine
> But For u3 update , Changelog topic has the *expected Outcome* but Output
> topic has *incorrect* data.
>
> *{*}Sequence:{*}*
> |Step|Reduction |ChangelogTopic|OutputTopic |
> |------ |----------------------------|-------------------|-------------|
> |Initial |M0 |M0 |
> |u1 |M1 = reduce(M0, u1) |M1 |M1 |
> |u2 |M2 = reduce(M1, u2) |M2 |M2 |
> |u3 |M3 = reduce(M2, u3) |M3 |❌ Actually:
> reduce(M1, u3) |
>
> Environment:
> - Kafka-clients:3.5.1
> - kafka-streams:3.5.1
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
