GitHub user apurvam opened a pull request:
https://github.com/apache/kafka/pull/4004
KAFKA-6003: Accept appends on replicas unconditionally when local producer
state doesn't exist
Without this patch, if the replica's log was somehow truncated before
the leader's it is possible for the replica fetcher thread to
continuously through an OutOfOrderSequenceException because the
incoming sequence would be non-zero and there is no local state.
This patch changes the behavior so that the replica state is updated to
the leader's state if there was no local state for the producer at the
time of the append.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apurvam/kafka
KAFKA-6003-handle-unknown-producer-on-replica
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4004.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4004
----
commit 341a0d2ba3ec0716f1830860869bf773f1bf8d85
Author: Apurva Mehta <apu...@confluent.io>
Date: 2017-10-02T22:41:19Z
KAFKA-6003: Accept appends on replicas unconditionally when local
producer state doesn't exist.
Without this patch, if the replica's log was somehow truncated before
the leader's it is possible for the replica fetcher thread to
continuously through an OutOfOrderSequenceException because the
incoming sequence would be non-zero and there is no local state.
This patch changes the behavior so that the replica state is updated to
the leader's state if there was no local state for the producer at the
time of the append.
----
---
