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 2492F200CC2 for ; Wed, 5 Jul 2017 16:24:42 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 22E3B1636B4; Wed, 5 Jul 2017 14:24:42 +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 8EBF61636B3 for ; Wed, 5 Jul 2017 16:24:41 +0200 (CEST) Received: (qmail 90833 invoked by uid 500); 5 Jul 2017 14:24:39 -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 Delivered-To: moderator for dev@kafka.apache.org Received: (qmail 74362 invoked by uid 99); 4 Jul 2017 11:29:53 -0000 X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -5.801 X-Spam-Level: X-Spam-Status: No, score=-5.801 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, HTML_OBFUSCATE_05_10=0.001, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H2=-2.8, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001] autolearn=disabled From: "Daehn, Werner" To: "dev@kafka.apache.org" Subject: Transactional Consistency beyond KIP-98 (transactional consumer) Thread-Topic: Transactional Consistency beyond KIP-98 (transactional consumer) Thread-Index: AdL0uNRi3qtwixMXRzaoLrwUO2TajQ== Date: Tue, 4 Jul 2017 11:29:43 +0000 Message-ID: <1589edb4cf434b159402895bc0229b21@sap.com> Accept-Language: de-DE, en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [10.21.23.231] Content-Type: multipart/alternative; boundary="_000_1589edb4cf434b159402895bc0229b21sapcom_" MIME-Version: 1.0 archived-at: Wed, 05 Jul 2017 14:24:42 -0000 --_000_1589edb4cf434b159402895bc0229b21sapcom_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable While the new transactional consistency feature is definitely a move into t= he right direction, I find the current design limitations quite severe. Und= erstandable but severe. First is the offset being the add-time, not the commit time. The consequenc= e of that is, if one transactional producer adds rows every once a while an= d does commit minutes or hours later, all consumers with read=3Dcommitted w= ill not see any other producer's data until this one did the commit. Will d= ecrease the stability of the overall solution, won't it? Would have been better to use the commit time as the offset value. Harder t= o implement but more stable. The other issue is at the consumer side. Current implementation does not pr= ovide transaction guarantees on the consumers. Again, for logical reasons a= nd to simplify the implementation, but as a user you want to have both - wh= en data is committed together you want to read the entire transaction as on= e unit and complete. Are there any plans to go beyond the current implementation? Thanks in advance --_000_1589edb4cf434b159402895bc0229b21sapcom_--