From dev-return-104926-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Wed Jun 12 19:57:14 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id CAEAE18061A for ; Wed, 12 Jun 2019 21:57:13 +0200 (CEST) Received: (qmail 56881 invoked by uid 500); 12 Jun 2019 19:57:11 -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 56870 invoked by uid 99); 12 Jun 2019 19:57:11 -0000 Received: from mailrelay1-us-west.apache.org (HELO mailrelay1-us-west.apache.org) (209.188.14.139) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Jun 2019 19:57:11 +0000 Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id D6A10E2D88 for ; Wed, 12 Jun 2019 19:57:04 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id CFD9E24656 for ; Wed, 12 Jun 2019 19:57:00 +0000 (UTC) Date: Wed, 12 Jun 2019 19:57:00 +0000 (UTC) From: "Jason Gustafson (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Resolved] (KAFKA-8483) Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/KAFKA-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8483. ------------------------------------ Resolution: Fixed Fix Version/s: 2.3.0 > Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error > --------------------------------------------------------------------------- > > Key: KAFKA-8483 > URL: https://issues.apache.org/jira/browse/KAFKA-8483 > Project: Kafka > Issue Type: Bug > Reporter: Jason Gustafson > Assignee: Jason Gustafson > Priority: Major > Fix For: 2.3.0 > > > The idempotent producer attempts to detect spurious UNKNOWN_PRODUCER_ID errors and handle them by reassigning sequence numbers to the inflight batches. The inflight batches are tracked in a PriorityQueue. The problem is that the reassignment of sequence numbers depends on the iteration order of PriorityQueue, which does not guarantee any ordering. So this can result in sequence numbers being assigned in the wrong order. -- This message was sent by Atlassian JIRA (v7.6.3#76005)