From dev-return-104727-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Tue Jun 4 22:53:04 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 EB2D618064D for ; Wed, 5 Jun 2019 00:53:03 +0200 (CEST) Received: (qmail 59169 invoked by uid 500); 4 Jun 2019 22:53:01 -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 59138 invoked by uid 99); 4 Jun 2019 22:53:01 -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; Tue, 04 Jun 2019 22:53:01 +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 5FC67E2D0E for ; Tue, 4 Jun 2019 22:53:00 +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 15CA02459C for ; Tue, 4 Jun 2019 22:53:00 +0000 (UTC) Date: Tue, 4 Jun 2019 22:53:00 +0000 (UTC) From: "Jason Gustafson (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (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 Jason Gustafson created KAFKA-8483: -------------------------------------- Summary: 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 The 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)