From dev-return-110531-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Wed Jan 15 23:09:03 2020 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 6C89D18065E for ; Thu, 16 Jan 2020 00:09:03 +0100 (CET) Received: (qmail 91803 invoked by uid 500); 15 Jan 2020 23:09:02 -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 91791 invoked by uid 99); 15 Jan 2020 23:09: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; Wed, 15 Jan 2020 23:09:01 +0000 Received: from jira-he-de.apache.org (static.172.67.40.188.clients.your-server.de [188.40.67.172]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 98DDFE00A5 for ; Wed, 15 Jan 2020 23:09:00 +0000 (UTC) Received: from jira-he-de.apache.org (localhost.localdomain [127.0.0.1]) by jira-he-de.apache.org (ASF Mail Server at jira-he-de.apache.org) with ESMTP id 13CC47800CB for ; Wed, 15 Jan 2020 23:09:00 +0000 (UTC) Date: Wed, 15 Jan 2020 23:09:00 +0000 (UTC) From: "Matthias J. Sax (Jira)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (KAFKA-9441) Refactor commit logic MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Matthias J. Sax created KAFKA-9441: -------------------------------------- Summary: Refactor commit logic Key: KAFKA-9441 URL: https://issues.apache.org/jira/browse/KAFKA-9441 Project: Kafka Issue Type: Sub-task Components: streams Reporter: Matthias J. Sax Using producer per thread in combination with EOS, it's not possible any longer to commit individual task independently (as done currently). We need to refactor StreamsThread, to commit all tasks at the same time for the new model. -- This message was sent by Atlassian Jira (v8.3.4#803005)