Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id C66B7200D20 for ; Tue, 3 Oct 2017 00:44:25 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id C52B8160BCB; Mon, 2 Oct 2017 22:44:25 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 3BCF31609EF for ; Tue, 3 Oct 2017 00:44:25 +0200 (CEST) Received: (qmail 86592 invoked by uid 500); 2 Oct 2017 22:44:24 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 86567 invoked by uid 99); 2 Oct 2017 22:44:23 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Oct 2017 22:44:23 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id AFE8FF571A; Mon, 2 Oct 2017 22:44:23 +0000 (UTC) From: apurvam To: dev@kafka.apache.org Reply-To: dev@kafka.apache.org Message-ID: Subject: [GitHub] kafka pull request #4004: KAFKA-6003: Accept appends on replicas uncondition... Content-Type: text/plain Date: Mon, 2 Oct 2017 22:44:23 +0000 (UTC) archived-at: Mon, 02 Oct 2017 22:44:26 -0000 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 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. ---- ---