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 D54E8200D44 for ; Mon, 20 Nov 2017 13:00:27 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id D3903160BF9; Mon, 20 Nov 2017 12:00:27 +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 F2CFD160BEC for ; Mon, 20 Nov 2017 13:00:26 +0100 (CET) Received: (qmail 65817 invoked by uid 500); 20 Nov 2017 12:00:25 -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 65796 invoked by uid 99); 20 Nov 2017 12:00:25 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Nov 2017 12:00:25 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id B55231A211C for ; Mon, 20 Nov 2017 12:00:24 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.23 X-Spam-Level: *** X-Spam-Status: No, score=3.23 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=2, KAM_INFOUSMEBIZ=0.75, KAM_NUMSUBJECT=0.5, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id xAVDOUzjCuEZ for ; Mon, 20 Nov 2017 12:00:21 +0000 (UTC) Received: from mail-qt0-f176.google.com (mail-qt0-f176.google.com [209.85.216.176]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 4ABB35F366 for ; Mon, 20 Nov 2017 12:00:20 +0000 (UTC) Received: by mail-qt0-f176.google.com with SMTP id n32so14431435qtb.2 for ; Mon, 20 Nov 2017 04:00:20 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:sender:in-reply-to:references:from:date:message-id :subject:to; bh=ZBepJ1CNgfmmcoWeh9sCiUfFSfALq+3/dvCyAEOUvNQ=; b=BSOyITU9ohIQWZJ4iAC/tZd0ZtBW+hsWb5t+SoEO7y4sgswABzRccCQTa0KrI6zpHm W8J9ckPtaaM9nUf6KaLe/8o95qZmNZND7/BK+arUn9kCcWhx568cNDiswguCujDtnIVa frY1JmT6jOKfCUAHpisHyuNV9IjH27E3YCD1k+FRA8J89Bmik/WU3UsPThk24LS2HR0e oalXOrbvvJCOeBGdrZB91ofDorAhB2jIwpzg/DSlmJAuZRPDZPGicyELx7GaHcgfNEuH Jn3FYh8oJ/2MOM4j5D6fJlVuKSjkQDyP8Ta0vVC0jlEtnOCY91qRzXJ8K1eG17lo2yF3 bIag== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:sender:in-reply-to:references:from :date:message-id:subject:to; bh=ZBepJ1CNgfmmcoWeh9sCiUfFSfALq+3/dvCyAEOUvNQ=; b=Wimb/UxceDPdM0AXCdWx8OEuW7v43wsc6dibeiOsBa4bT1oa+crvCKs0Kiml3b7Qq0 ljRNXKATHlY905DrBdMgKpqHXsJMztxZ/+NHsO7Vf9Wst3ba5IMoS1QSGsP+uEfyCCPo ne5nyNyJjVu6DY3ObDP1y+5zYOgEVersmPoNdXBP0ZzkJhU4flvqmDz4nCyN9gI+q4bo 5RKjAmJyKjlvueAMrusNvG/v1D2vHmNyCDDbFGVPN+v9/06RzEWCnu72dKFDJzqHr291 XNeLydR9XaIW/eVtXiuEMIOOiTRaDoU07juAq+FVkxdg/+rQ6BQkvbu6wKzi99/Y9xzQ 3ReA== X-Gm-Message-State: AJaThX6ebgGSitGjc+LK64DywX5VMeQb7saoez5Y3Sk6eLVL54mW3WdZ 3nR2wkfVZN1lq5UMOEmJ7mv7U39OfRczR5jVSESGNg== X-Google-Smtp-Source: AGs4zMZAVQztkK0RZiK19b0F5wmUvDY/4tADVz4YKxeGgNGhORkuj0eogWUqMmIKDyWVsGm5o1p+qw/r3qIqMVG9+9U= X-Received: by 10.200.27.36 with SMTP id y33mr21807912qtj.291.1511179212930; Mon, 20 Nov 2017 04:00:12 -0800 (PST) MIME-Version: 1.0 Sender: ismaelj@gmail.com Received: by 10.12.168.153 with HTTP; Mon, 20 Nov 2017 03:59:32 -0800 (PST) In-Reply-To: References: <786d35ca-d8c4-9781-d057-c46a5de2afc5@gmail.com> From: Ismael Juma Date: Mon, 20 Nov 2017 11:59:32 +0000 X-Google-Sender-Auth: hbueuWePqEHkDZ_NkfZB-CIw5Qc Message-ID: Subject: Re: [DISCUSS] Kafka 2.0.0 in June 2018 To: dev , Onur Karaman Content-Type: multipart/alternative; boundary="94eb2c142b362dcdd4055e68d477" archived-at: Mon, 20 Nov 2017 12:00:28 -0000 --94eb2c142b362dcdd4055e68d477 Content-Type: text/plain; charset="UTF-8" Thanks for the update Onur. Are you and the other committers and contributors from LinkedIn planning to push this over the line? Ismael On Fri, Nov 10, 2017 at 9:53 PM, Onur Karaman wrote: > Hey everyone. Regarding the status of KIP-125, just a heads up: I have an > implementation of KIP-125 (KAFKA-4513) here: > https://github.com/onurkaraman/kafka/commit/3b5448006ab70ba2b0b5e177853d19 > 1d0f777452 > > The code might need to be rebased. The steps described in the KIP are a bit > involved. Other than that, the implementation might have a bug with respect > to converting arbitrary blacklist regexes to whitelist regexes since the > new consumer only accepts whitelists. > > On Fri, Nov 10, 2017 at 11:36 AM, Jeff Widman wrote: > > > Re: migrating offsets for old Scala consumers. > > > > I work in the python world, so haven't directly used the old high level > > consumer, but from what I understand the underlying problem remains the > > migration of zookeeper offsets to the __consumer_offsets topic. > > > > We've used a slightly modified version of Grant Henke's script for > > migrating offsets here: https://github.com/apache/kafka/pull/2615 > > It doesn't support rolling upgrades, but other than that it's great... > I've > > used it for multiple migrations, and very thankful for the time Grant put > > into it. > > > > I don't know that it's worth pulling this into core, it might be, it > might > > not be. But it probably is worth documenting the procedure at least > > somewhere. > > > > Personally, I suspect that those who absolutely need a rolling migration > > and cannot handle a short period of downtime while doing a migration > > probably have in-house experts on Kafka who are familiar with the issues > > and willing to figure out a solution. The rest of the world can generally > > handle a short maintenance window. > > > > > > > > > > On Fri, Nov 10, 2017 at 10:46 AM, Ismael Juma wrote: > > > > > Hi Gwen, > > > > > > A KIP has been proposed, but it is stalled: > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-125%3A+ > > > ZookeeperConsumerConnector+to+KafkaConsumer+Migration+and+Rollback > > > > > > Unless the interested parties pick that up, we would drop support > > without a > > > rolling upgrade path. Users would be able to use the old consumers from > > > 1.1.x for a long time. The old Scala clients don't support the message > > > format introduced in 0.11.0, so the feature set is pretty much frozen > and > > > there's little benefit in upgrading. But there is a cost in keeping > them > > in > > > the codebase. > > > > > > Ismael > > > > > > On Fri, Nov 10, 2017 at 6:02 PM, Gwen Shapira > wrote: > > > > > > > Last time we tried deprecating the Scala consumer, there were > concerns > > > > about a lack of upgrade path. There is no rolling upgrade, and > > migrating > > > > offsets is not trivial (and not documented). > > > > > > > > Did anything change in that regard? Or are we planning on dropping > > > support > > > > without an upgrade path? > > > > > > > > > > > > On Fri, Nov 10, 2017 at 5:37 PM Guozhang Wang > > > wrote: > > > > > > > > > Thanks Ismael, the proposal looks good to me. > > > > > > > > > > A side note regarding: https://issues.apache.org/ > > > jira/browse/KAFKA-5637, > > > > > could we resolve this ticket sooner than later to make clear about > > the > > > > code > > > > > deprecation and support duration when moving from 1.0.x to 2.0.x? > > > > > > > > > > > > > > > Guozhang > > > > > > > > > > > > > > > On Fri, Nov 10, 2017 at 3:44 AM, Ismael Juma > > > wrote: > > > > > > > > > > > Features for 2.0.0 will be known after 1.1.0 is released in > > February > > > > > 2018. > > > > > > We are still doing the usual time-based release process[1]. > > > > > > > > > > > > I am raising this well ahead of time because of the potential > > impact > > > of > > > > > > removing the old Scala clients (particularly the old high-level > > > > consumer) > > > > > > and dropping support for Java 7. Hopefully users can then plan > > > > > accordingly. > > > > > > We would do these changes in trunk soon after 1.1.0 is released > > > (around > > > > > > February). > > > > > > > > > > > > I think it makes sense to complete some of the work that was not > > > ready > > > > in > > > > > > time for 1.0.0 (Controller improvements and JBOD are two that > come > > to > > > > > mind) > > > > > > in 1.1.0 (January 2018) and combined with the desire to give > > advance > > > > > > notice, June 2018 was the logical choice. > > > > > > > > > > > > There is no plan to support a particular release for longer. 1.x > > > versus > > > > > 2.x > > > > > > is no different than 0.10.x versus 0.11.x from the perspective of > > > > > > supporting older releases. > > > > > > > > > > > > [1] https://cwiki.apache.org/confluence/display/KAFKA/Time+ > > > > > > Based+Release+Plan > > > > > > > > > > > > On Fri, Nov 10, 2017 at 11:21 AM, Jaikiran Pai < > > > > jai.forums2013@gmail.com > > > > > > > > > > > > wrote: > > > > > > > > > > > > > Hi Ismael, > > > > > > > > > > > > > > Are there any new features other than the language specific > > changes > > > > > that > > > > > > > are being planned for 2.0.0? Also, when 2.x gets released, will > > the > > > > 1.x > > > > > > > series see continued bug fixes and releases in the community or > > is > > > > the > > > > > > plan > > > > > > > to have one single main version that gets continuous updates > and > > > > > > releases? > > > > > > > > > > > > > > By the way, why June 2018? :) > > > > > > > > > > > > > > -Jaikiran > > > > > > > > > > > > > > > > > > > > > > > > > > > > On 09/11/17 3:14 PM, Ismael Juma wrote: > > > > > > > > > > > > > >> Hi all, > > > > > > >> > > > > > > >> I'm starting this discussion early because of the potential > > > impact. > > > > > > >> > > > > > > >> Kafka 1.0.0 was just released and the focus was on achieving > the > > > > > > original > > > > > > >> project vision in terms of features provided while maintaining > > > > > > >> compatibility for the most part (i.e. we did not remove > > deprecated > > > > > > >> components like the Scala clients). > > > > > > >> > > > > > > >> This was the right decision, in my opinion, but it's time to > > start > > > > > > >> thinking > > > > > > >> about 2.0.0, which is an opportunity for us to remove major > > > > deprecated > > > > > > >> components and to benefit from Java 8 language enhancements > (so > > > that > > > > > we > > > > > > >> can > > > > > > >> move faster). So, I propose the following for Kafka 2.0.0: > > > > > > >> > > > > > > >> 1. It should be released in June 2018 > > > > > > >> 2. The Scala clients (Consumer, SimpleConsumer, Producer, > > > > > SyncProducer) > > > > > > >> will be removed > > > > > > >> 3. Java 8 or higher will be required, i.e. support for Java 7 > > will > > > > be > > > > > > >> dropped. > > > > > > >> > > > > > > >> Thoughts? > > > > > > >> > > > > > > >> Ismael > > > > > > >> > > > > > > >> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- > > > > > -- Guozhang > > > > > > > > > > > > > > > > > > > > -- > > > > *Jeff Widman* > > jeffwidman.com | 740-WIDMAN-J (943-6265) > > <>< > > > --94eb2c142b362dcdd4055e68d477--