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 B7D86200D57 for ; Mon, 11 Dec 2017 22:33:55 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id B64D3160C13; Mon, 11 Dec 2017 21:33:55 +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 07BDB160C03 for ; Mon, 11 Dec 2017 22:33:54 +0100 (CET) Received: (qmail 18689 invoked by uid 500); 11 Dec 2017 21:33:53 -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 18677 invoked by uid 99); 11 Dec 2017 21:33:53 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Dec 2017 21:33:53 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id EB97DC6557 for ; Mon, 11 Dec 2017 21:33:52 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.979 X-Spam-Level: * X-Spam-Status: No, score=1.979 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, 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: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=confluent-io.20150623.gappssmtp.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id m19ylhriqRpD for ; Mon, 11 Dec 2017 21:33:49 +0000 (UTC) Received: from mail-qt0-f173.google.com (mail-qt0-f173.google.com [209.85.216.173]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id CC25860F75 for ; Mon, 11 Dec 2017 21:31:19 +0000 (UTC) Received: by mail-qt0-f173.google.com with SMTP id g10so42276839qtj.12 for ; Mon, 11 Dec 2017 13:31:19 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=confluent-io.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=qww752VZwHn6IbVui1Vm2n3hJdLBJ0HGPkn4OAkdAKg=; b=Z5DK9EdnfZrvzbPd8LklZ14OwQk5YRbTwUxnl8JHs1sAcbXk9I82qDJwT8cl1E2rq5 anOwG2k/eStX8GbVK+5kZZhTarltvkURfirpxUuNc2bVZoshh9qA9wTgJvigKPJ/x1aK TrvMZItOZJX9J8UL7RUZXYfpgsJJxLBjmlfZI5rHwnZWhJcFYVtLplN96J1r8Us4SC/f gGnEq4j45WPCtplA5jrB8Ok60eCr83LGbhYbcQPDWmJAZIka27IP9sjSXNeOOzGVzcUp tyB1zuPfuts7WwIP/clv3RaliZK3JRRl/bEEYCYFHUgrJCYd4acdpiRuPLe6+2DiacwJ Ht+g== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=qww752VZwHn6IbVui1Vm2n3hJdLBJ0HGPkn4OAkdAKg=; b=pylWrbLiHkzum/TUfNpLMG+fk/zoyHrs2mRWnkK8pGHUXm5xAhD89LGA2kMNZQExMx aE/uWRRce+2qp+CWyTqUUvZnrUbvtZQEocmHa6wzpP0R99KXAafOXTkKSsd160RlOG5h nKyaN9G5xbxrDlqf/wQQIOCwq/dDbifOV7u4DtOWTwUWbjIkmlxTWOiwgSNlGvRptIop o6xRpECUBk1GswqqEj3s/xPiB/NWpMyqRYjWTc7Fhz3/jdzIUq8V+a3Q1QxfXZRxgosC glc8p/uv5u6zIuadWKHph15VVOf2C5yLv1ZK7Wml1cedI2an9txG6bhF0+Q3Vs1BrCrT fvyw== X-Gm-Message-State: AKGB3mJTeRs6XeZtg8j/Ipj4o5h6ySsNr67rIRUKPc7SBc2NFO5yznKk wYLSbkzarBPkSxVFoEswUEU+Ybw35rwDW31A0A/gv0drWCc= X-Google-Smtp-Source: ACJfBov2/Cy6Vky7M0gS1NfMKaBvsrexthEp9GrxpGpkkeN4VUNLxqUYbQWoP1QT9siXyTRZWLhjMDmyT8v4Gb1Wh2E= X-Received: by 10.55.54.8 with SMTP id d8mr2714230qka.122.1513027879202; Mon, 11 Dec 2017 13:31:19 -0800 (PST) MIME-Version: 1.0 Received: by 10.12.146.151 with HTTP; Mon, 11 Dec 2017 13:31:18 -0800 (PST) In-Reply-To: References: From: Jun Rao Date: Mon, 11 Dec 2017 13:31:18 -0800 Message-ID: Subject: Re: [DISCUSS] KIP-236 Interruptible Partition Reassignment To: "dev@kafka.apache.org" Content-Type: multipart/alternative; boundary="001a114717e246907705601741bd" archived-at: Mon, 11 Dec 2017 21:33:55 -0000 --001a114717e246907705601741bd Content-Type: text/plain; charset="UTF-8" Another question is on the compatibility. Since now there are 2 ways of specifying a partition reassignment, one under /admin/reassign_partitions and the other under /admin/reassignments, we probably want to prevent the same topic being reassigned under both paths at the same time? Thanks, Jun On Fri, Dec 8, 2017 at 5:41 PM, Jun Rao wrote: > Hi, Tom, > > Thanks for the KIP. It definitely addresses one of the pain points in > partition reassignment. Another issue that it also addresses is the ZK node > size limit when writing the reassignment JSON. > > My only concern is that the KIP needs to create one watcher per reassigned > partition. This could add overhead in ZK and complexity for debugging when > lots of partitions are being reassigned simultaneously. We could > potentially improve this by introducing a separate ZK path for change > notification as we do for configs. For example, every time we change the > assignment for a set of partitions, we could further write a sequential > node /admin/reassignment_changes/[change_x]. That way, the controller > only needs to watch the change path. Once a change is triggered, the > controller can read everything under /admin/reassignments/. > > Jun > > > On Wed, Dec 6, 2017 at 1:19 PM, Tom Bentley wrote: > >> Hi, >> >> This is still very new, but I wanted some quick feedback on a preliminary >> KIP which could, I think, help with providing an AdminClient API for >> partition reassignment. >> >> https://cwiki.apache.org/confluence/display/KAFKA/KIP-236% >> 3A+Interruptible+Partition+Reassignment >> >> I wasn't sure whether to start fleshing out a whole AdminClient API in >> this >> KIP (which would make it very big, and difficult to read), or whether to >> break it down into smaller KIPs (which makes it easier to read and >> implement in pieces, but harder to get a high-level picture of the >> ultimate >> destination). For now I've gone for a very small initial KIP, but I'm >> happy >> to sketch the bigger picture here if people are interested. >> >> Cheers, >> >> Tom >> > > --001a114717e246907705601741bd--