Re: [VOTE] KIP-371: Add a configuration to build custom SSL principal name

Hi All, The vote has passed with 3 binding votes (Harsha, Rajini, Jun) and 2 non-binding votes (Priyank, Satish). Thanks everyone for the votes. Thanks, Manikumar On Wed, Oct 10, 2018 at 1:36 AM Jun Rao wrote: > Hi, Mani, > > Thanks for the KIP. +1 from me. > > Jun > >

Re: [ANNOUNCE] New Committer: Manikumar Reddy

Thanks everyone! It has been a great learning experience working Apache Kafka community. I am thankful to the committers/community members for all the support and help. Thanks Manikumar On Fri, Oct 12, 2018 at 1:55 PM Edoardo Comar wrote: > Well done Maniku

[DISCUSS] 2.0.1 bug fix release

( https://issues.apache.org/jira/browse/KAFKA-7464). Next week, Once the blocking issue gets addressed, I plan to create the first RC for 2.0.1 release. Thanks, Manikumar

[VOTE] 2.0.1 RC0

/~manikumar/kafka-2.0.1-rc0/RELEASE_NOTES.html *** Please download, test and vote by Tuesday, October 30, end of day Kafka's KEYS file containing PGP keys we use to sign the release: http://kafka.apache.org/KEYS * Release artifacts to be voted upon (source and binary): http://home.apach

Re: Frequent under-replicated partitions

We can monitor below replica related metrics. Try tuning " replica.lag.time.max.ms" , "replica.fetch.max.bytes" . look for logs starting with "Shrinking ISR for partition ...". kafka.server:type=ReplicaManager,name=IsrShrinksPerSec kafka.server:type=ReplicaManager,name=IsrExpandsPerSec kafka.serv

Re: [VOTE] 2.1.0 RC0

minor observation: config sections are empty in the documentation page. http://kafka.apache.org/21/documentation.html#producerconfigs On Wed, Oct 24, 2018 at 10:49 PM Ted Yu wrote: > +1 > > InternalTopicIntegrationTest failed during test suite run but passed with > rerun. > > On Wed, Oct 24, 201

Re: [VOTE] 2.0.1 RC0

e. Run with --info or > --debug option to get more log output. Run with --scan to get full > insights. > > * Get more help at https://help.gradle.org > > BUILD FAILED in 3s > " > Eno > > On Fri, Oct 26, 2018 at 3:29 AM Manikumar > wrote: > > > Hell

Re: 請求加入 Jira & Confluence 的權限

Hi, Navya Thanks for your interest. Gave you permission to both jira and wiki. Thanks, On Wed, Oct 31, 2018 at 1:57 PM 張育琦 wrote: > 請求加入 Jira & Confluence 的權限 ： > > Jira id ：Navya Snow > cwiki id ：NavyaSnow > > 謝謝！ > > > Best regards, > 亦思科技is-land > Navya Chang 張育琦 > 產品應用部-

Re: [VOTE] 2.0.1 RC0

We were waiting for the system test results. There were few failures: KAFKA-7579, KAFKA-7559, KAFKA-7561 they are not blockers for 2.0.1 release. We need more votes from PMC/committers :) Thanks Stanislav! for the system test results. Thanks, Manikumar On Thu, Nov 1, 2018 at 10:20 PM Eno

Re: [VOTE] 2.0.1 RC0

ked as blockers, although it's not clear to me if > they really are. Any update? > Thanks > Eno > > On Thu, Nov 1, 2018 at 5:10 PM Manikumar > wrote: > > > We were waiting for the system test results. There were few failures: > > KAFKA-7579, KAFKA-7559, KAFKA

Re: [kafka-clients] Re: [VOTE] 2.0.1 RC0

+1 (binding) Built from src and ran tests, verified the artifacts, signatures, Ran core quick start. Thanks, Manikumar On Thu, Nov 8, 2018 at 12:15 AM Rajini Sivaram wrote: > +1 (binding) > > Checked source build and unit tests. Ran quickstart with source and binary. > > Thank y

Re: [kafka-clients] Re: [VOTE] 2.0.1 RC0

Yes, I was about to send closing mail. On Thu, Nov 8, 2018 at 9:39 PM Ismael Juma wrote: > Manikumar, looks like you have the necessary votes. :) > > Ismael > > On Wed, Nov 7, 2018, 10:45 AM Rajini Sivaram wrote: > >> +1 (binding) >> >> Checked source build

[RESULTS] [VOTE] Release Kafka version 2.0.1

This vote passes with 12 +1 votes (3 bindings) and no 0 or -1 votes. +1 votes PMC Members: * Jun Rao * Gwen Shapira * Rajini Sivaram Committers: * Harsha * Ewen Cheslack-Postava * Manikumar Community: * Magnus Edenhill * Eno Thereska * Vahid Hashemian * Jakub Scholz * Satish Duggana * Mickael

[ANNOUNCE] Apache Kafka 2.0.1

Roesler, Jon Lee, Kamal Chandraprakash, Kevin Lafferty, Konstantine Karantasis, lambdaliu, Lincong Li, Lucas Wang, Maciej Bryński, Manikumar Reddy, Matthias J. Sax, Max Zheng, Michal Dziemianko, Michał Borowiecki, radai-rosenblatt, Rajini Sivaram, Randall Hauch, Robert Yokota, Simon Clark, Stanislav

Re: [VOTE] 2.1.0 RC1

+1 I've verified signature, docs, built from sources, ran unit tests (no test failures observed) ran quick start. Thanks for running the release!. Thanks, Manikumar On Sat, Nov 17, 2018 at 1:10 PM Dong Lin wrote: > Hey Eno, Vahid and everyone, > > Thanks for reporting the test

Re: Need to subscribe to mail list and get access to contribute to jira tickets

Hi, I have given JIRA permissions for "kaushik srinivas" JIRA username. On Tue, Nov 20, 2018 at 3:29 PM KAUSHIK SRINIVAS < kaushiksrinivas...@gmail.com> wrote: > Hi, > > Need subscription to kafka mailing list. > > Also need to assign jira tickets to myself. Have worked on few pull > requests an

Re: [VOTE] KIP-351: Add --under-min-isr option to describe TopicCommand

+1 (binding) Thanks for the KIP. Can you update the KIP stating that this option is not supported with "--zookeeper" option. On Mon, Nov 26, 2018 at 11:15 PM Mickael Maison wrote: > +1 (non-binding) > Thanks for the KIP! > On Mon, Nov 26, 2018 at 4:32 PM Kevin Lu wrote: > > > > Hi All, > > > >

Re: Requesting permission to create KIP

Thanks for your interest. I have given you the permissions. On Thu, Nov 29, 2018 at 8:24 PM Brandon Kirchner wrote: > Hello, > > Could you please grant me (brandon.kirchner) permission to create a KIP? > > Thanks! > Brandon K. >

Re: I'd like permissions to publish a KIP

Thanks for your interest. I have given you the wiki permissions. On Thu, Nov 29, 2018 at 10:03 PM Noa Resare wrote: > Greetings friends, > > I have a proposal for a tiny change that would alter configuration > semantics slightly, so it seems like something that should be handled > through the KI

Re: kafka Build fail - jdk 8 - #18041

HI Srinivas, They are mostly transient test failures. We can rerun the test to confirm the failures. You can re-trigger the jenkins tests by commenting "retest this please" in PR comments. On Fri, Nov 30, 2018 at 12:04 PM Srinivas, Kaushik (Nokia - IN/Bangalore) < kaushik.srini...@nokia.com> wr

Re: Request for wiki permission to create KIP

Hi Kamal, I just gave you wiki permissions; Thanks, On Sat, Dec 1, 2018 at 11:29 AM Kamal Chandraprakash < kamal.chandraprak...@gmail.com> wrote: > Hi, > > I would like to propose a KIP for KAFKA-7499 > . Please grant me > permission to create K

Re: [DISCUSS] KIP-373: Allow users to create delegation tokens for other users

Bump up! to get some attention. BTW, recently Apache Spark added for Kafka delegation token support. https://issues.apache.org/jira/browse/SPARK-25501 On Tue, Sep 25, 2018 at 9:56 PM Manikumar wrote: > Hi all, > > I have created a KIP that proposes to allow users to create delegation

Re: [DISCUSS] KIP-373: Allow users to create delegation tokens for other users

Bump up! to get some attention. BTW, recently Apache Spark added support for Kafka delegation token. https://issues.apache.org/jira/browse/SPARK-25501 On Fri, Dec 7, 2018 at 5:27 PM Manikumar wrote: > Bump up! to get some attention. > > BTW, recently Apache Spark added for Kafka d

Re: [DISCUSS] KIP-395: Encypt-then-MAC Delegation token metadata

ZooKeeper and pluggable interfaces for custom implementations. What do you think? Thanks, Manikumar On Sat, Dec 1, 2018 at 9:37 PM Attila Sasvári wrote: > Hi All, > > I have a proposal to allow Kafka brokers to encrypt sensitive metadata > information about delegation tokens. &

Re: [DISCUSS] KIP-373: Allow users to create delegation tokens for other users

authenticated connections. Thanks, Manikumar On Fri, Dec 7, 2018 at 11:56 PM Harsha wrote: > Hi Mani, > Overall KIP looks good to me. Can we call this Impersonation > support, which is what the KIP is doing? > Also instead of using super.uses as the config which essent

Re: Permissions to edit KIP page and ...

I just gave you permissions. Thanks. On Wed, Dec 12, 2018 at 7:50 PM Per Steffensen wrote: > Hi > > I used to have permissions to edit KIP page > ( > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals). > > Now suddenly I do not. I created KIP-381 and now wanted to cha

Re: Fail-fast builds?

+1 fo the suggestion. On Fri, Dec 21, 2018 at 2:38 AM David Arthur wrote: > In the jenkins.sh file, we have the following comment: > > "In order to provide faster feedback, the tasks are ordered so that faster > tasks are executed in every module before slower tasks (if possible)" > > > but then

Re: [ANNOUNCE] New Committer: Vahid Hashemian

Congrats, Vahid! On Wed 16 Jan, 2019, 6:53 AM Ismael Juma Congratulations Vahid! > > On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson > > Hi All, > > > > The PMC for Apache Kafka has invited Vahid Hashemian as a project > > committer and > > we are > > pleased to announce that he has accepted! > >

Re: [VOTE] KIP-294 - Enable TLS hostname verification by default

+1 (non-binding) Thanks. On Wed, May 9, 2018 at 10:09 PM, Mickael Maison wrote: > +1, thanks for the KIP! > > On Wed, May 9, 2018 at 4:41 PM, Ted Yu wrote: > > +1 > > > > On Wed, May 9, 2018 at 8:28 AM, Rajini Sivaram > > wrote: > > > >> Hi all, > >> > >> Since there have been no objections o

Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position

+1 (non-binding). Thanks. On Thu, May 10, 2018 at 2:33 PM, Mickael Maison wrote: > +1 (non binding) > Thanks > > On Thu, May 10, 2018 at 9:39 AM, Rajini Sivaram > wrote: > > Hi Richard, Thanks for the KIP. > > > > +1 (binding) > > > > Regards, > > > > Rajini > > > > On Wed, May 9, 2018 at 10:54

Re: [VOTE] KIP-278: Add version option to Kafka's commands

+1 (non-binding) Thanks for the KIP. On Fri, May 11, 2018 at 12:56 PM, zhenya Sun wrote: > +1 building > > 在 2018年5月11日，上午9:51，Ted Yu 写道： > > > > +1 > > > > On Thu, May 10, 2018 at 6:42 PM, Sasaki Toru > > wrote: > > > >> Hi all, > >> > >> I would like to start the vote on KIP-278: Add versio

Re: [VOTE] KIP-255: OAuth Authentication via SASL/OAUTHBEARER

+1 (non-binding) Thanks for the detailed KIP. On Wed, May 16, 2018 at 5:59 PM, Mickael Maison wrote: > Thanks for the KIP, > +1 (non binding) > > On Wed, May 16, 2018 at 2:51 AM, Ron Dagostino wrote: > > Hi Jun. I think you are getting at the fact that OAuth 2 is a flexible > > framework that

Re: [VOTE] 1.1.1 RC0

+1 (non-binding) Ran test, Verified quick start, producer/consumer perf tests On Thu, Jun 21, 2018 at 11:58 AM zhenya Sun wrote: > +1 non-binding > > > 在 2018年6月21日，下午2:18，Andras Beni 写道： > > > > +1 (non-binding) > > > > Built .tar.gz, created a cluster from it and ran a basic end-to-end tes

[DISCUSS] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Hi all, I have created a KIP to add support for dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs *https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=85474993 * Any feedback i

Re: [kafka-clients] Re: [VOTE] 1.1.1 RC1

+1 (non-binding) Ran tests, Verified quick start, producer/consumer perf tests On Sat, Jun 23, 2018 at 8:11 AM Dong Lin wrote: > Thank you for testing and voting the release! > > I noticed that the date for 1.1.1-rc1 is wrong. Please kindly test and > vote by Tuesday, June 26, 12 pm PT. > >

Re: [VOTE] 1.0.2 RC0

+1 (non-binding) Verified tests, quick start, producer/consumer perf tests. On Sat, Jun 23, 2018 at 2:25 AM Ted Yu wrote: > +1 > > Ran test suite. > > Checked signatures. > > On Fri, Jun 22, 2018 at 11:42 AM, Vahid S Hashemian < > vahidhashem...@us.ibm.com> wrote: > > > +1 (non-binding) > > > >

[DISCUSS] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Hi all, I have created a minor KIP to return new error code for DeleteTopics API when topic deletion disabled. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=87295558 Please take a look. Thanks,

Re: [DISCUSS] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Hi, Thanks for the review. > nit: you are going to fill in an actual value below in your PR, right ? > private static final long serialVersionUID = 1L; > > We normally set the serialVersionUID = 1L in Kafka exception classes. In Motivation, please mention the IllegalStateException scenari

Re: [VOTE] KIP-324: Add method to get metrics() in AdminClient

+1 (non-binding) Thanks. On Wed, Jun 27, 2018 at 10:15 PM Matthias J. Sax wrote: > +1 (binding) > > On 6/26/18 2:33 PM, Guozhang Wang wrote: > > +1. Thanks. > > > > On Tue, Jun 26, 2018 at 2:31 PM, Yishun Guan wrote: > > > >> Hi All, > >> > >> I am starting a vote on this KIP: > >> > >> https:

Re: [DISCUSS] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Thanks for the responses. If there are no concerns, I will start the voting process soon. On Tue, Jun 26, 2018 at 10:14 PM Harsha wrote: > This is very useful. LGTM. > > Thanks, > Harsha > > On Mon, Jun 25th, 2018 at 10:20 AM, Dong Lin wrote: > > > > > >

[VOTE] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Hi All, I would like to start voting on KIP-308 which would add support for dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=85474993 Thanks,

Re: [kafka-clients] [VOTE] 2.0.0 RC1

looks like maven artifacts are not updated in the staging repo. They are still at old timestamp. https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/2.0.0/ On Sat, Jun 30, 2018 at 12:06 AM Rajini Sivaram wrote: > Hello Kafka users, developers and client-developers, >

Re: [kafka-clients] Re: [VOTE] 0.11.0.3 RC0

+1 (non-binding) Verified quick start, ran producer/consumer perf tests, Thanks On Sun, Jul 1, 2018 at 8:29 PM Ismael Juma wrote: > +1 (binding) > > Verified signature of source artifact, ran tests and verified quickstart > on source artifact with Java 7, verified quickstart on binary artifa

Re: [kafka-clients] Re: [VOTE] 1.0.2 RC1

+1 (non-binding) Verified tests, quick start, producer/consumer perf tests. On Sun, Jul 1, 2018 at 11:27 PM Ismael Juma wrote: > +1 (binding) > > Verified signature of source artifact, ran tests and verified quickstart > on source artifact with Java 7, verified quickstart on binary artifact (S

Re: [DISCUSS] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Since this is a minor KIP, If there are no concerns I will start voting thread. On Wed, Jun 27, 2018 at 2:24 PM Ted Yu wrote: > bq. set the serialVersionUID = 1L in Kafka exception classes > > Indeed. Should have checked earlier. > > On Wed, Jun 27, 2018 at 1:38 AM, Man

[VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Manikumar Fri, Jun 29, 7:59 PM (4 days ago) to dev Hi All, I would like to start voting on KIP-322 which would return new error code for DeleteTopics API when topic deletion disabled. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=87295558 Thanks,

Re: [VOTE] 2.0.0 RC1

+1 (non-binding) Verified the release notes, src, binary artifacts, Ran the test suite, Verified quick start, Ran producer/consumer perf test, log compaction tests Thanks On Wed, Jul 4, 2018 at 8:33 AM Brett Rann wrote: > +1 tentative > rolling upgrade of tiny shared staging multitenacy (200

Re: [VOTE] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

*Hi All,The vote has passed with 3 binding votes (Dong Lin, Rajini, Jason,) and one non-binding vote(Ted).Thanks everyone for the votes.Thanks,Manikumar* On Fri, Jun 29, 2018 at 9:34 PM Jason Gustafson wrote: > +1 > > Thanks Manikumar! > > On Fri, Jun 29, 2018 at 8:37 AM,

Re: [VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

; > > > > > > > > > > +1 (non binding) > > > > > > > > Thanks for the KIP > > > > > > > > > > > > > > > > On Tue, Jul 3, 2018 at 4:59 PM, Vahid S Hashemian > > > > > > > > < vahidhashem...@us.ibm.com > wrote:

Re: [DISCUSS] KIP-338 Support to exclude the internal topics in kafka-topics.sh command

LGTM. Thanks for the KIP. Thanks. On Wed, Jul 11, 2018 at 3:31 PM Chia-Ping Tsai wrote: > hi Kafka, > > KIP-338 is trying to make us exclude internal topics easily when using the > kafka-topics.sh. An new option will be added to kafka-topics.sh > (TopicCommand) and user can use the option to ex

Re: [VOTE] 1.1.1 RC3

+1 (non-binding) Ran tests, Verified quick start, producer/consumer perf tests On Thu, Jul 12, 2018 at 11:06 AM Brett Rann wrote: > +1 (non binding) > rolling upgrade of shared staging multitenacy (200+ consumer groups) > cluster from 1.1.0 to 1.1.1-rc3 using the kafka_2.11-1.1.1.tgz artifa

KIP-327: Add describe all topics API to AdminClient

Hi all, I have created a KIP to add describe all topics API to AdminClient . https://cwiki.apache.org/confluence/display/KAFKA/KIP-327%3A+Add+describe+all+topics+API+to+AdminClient Please take a look. Thanks,

Re: KIP-327: Add describe all topics API to AdminClient

th > > > different > > > > > releases> > of the JDK (there were some changes in java 8, for > > > example). > > > > > Also, re2> > regular expressions are linear time, never exponential > > > time. See > > > > > htt

Re: KIP-327: Add describe all topics API to AdminClient

Closing this KIP in favor of adding filtering support to the Metadata API and KIP-142. Will open a new KIP when ready. Thanks for your reviews. On Mon, Jul 16, 2018 at 8:38 AM Colin McCabe wrote: > Thanks, Manikumar. I've been meaning to bring up KIP-142 again. It would > definitel

Re: [VOTE] KIP-338 Support to exclude the internal topics in kafka-topics.sh command

+1 (non-binding) On Thu, Jul 19, 2018 at 11:47 PM Colin McCabe wrote: > +1 (non-binding) > > cheers, > Colin > > On Mon, Jul 16, 2018, at 01:10, Chia-Ping Tsai wrote: > > hi folks, > > > > The discussion[1] of KIP-338[2] did not get any objection for last 6 > > days so it is time to start the vo

Re: [VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Bumping this thread. On Tue, Jul 10, 2018 at 10:33 PM Manikumar wrote: > Waiting for one more binding vote to pass this minor KIP. Appreciate your > vote. > > On Wed, Jul 4, 2018 at 7:03 PM Eno Thereska > wrote: > >> +1 (non binding) >> >> On Wed, Jul 4, 2

Re: [VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

Hi Jason, Yes, we can return UNKNOWN_SERVER_ERROR for older versions. This will give better developer experience. Updated the KIP. Thanks, On Fri, Jul 20, 2018 at 11:02 PM Jason Gustafson wrote: > Hey Manikumar, > > This looks good. Do we have to keep the current behavior when han

Re: [VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

ght abuse, but at least it suggests an incompatibility between > what the client is requesting to do and what the server supports. > UNKNOWN_SERVER_ERROR, on the other hand, suggests an unexpected condition > on the broker. > > -Jason > > On Fri, Jul 20, 2018 at 10:57 AM,

Re: [VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.

*Hi All,The vote has passed with 3 binding votes (Gwen, Harsha, Jason) and 8 non-binding votes (Vahid, Mickael, Ted, Daniele, Satish, Magnus, Kamal, Eno).Thanks everyone for the votes.Thanks,Manikumar* On Sat, Jul 21, 2018 at 12:26 AM Jason Gustafson wrote: > Thanks, +1 from me. > &g

[DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Hi all, I have created a KIP to use AdminClient API in AclCommand (kafka-acls.sh) *https://cwiki.apache.org/confluence/display/KAFKA/KIP-332%3A+Update+AclCommand+to+use+AdminClient+API* Please

Re: [ANNOUNCE] Apache Kafka 2.0.0 Released

y, Dong Lin, Edoardo Comar, emmanuel Harel, > > Eugene Sevastyanov, Ewen Cheslack-Postava, Fedor Bobin, fedosov-alexander, > > Filipe Agapito, Florian Hussonnois, fredfp, Gilles Degols, gitlw, Gitomain, > > Guangxian, Gunju Ko, Gunnar Morling, Guozhang Wang, hmcl, huxi, huxihx, >

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Bumping this up! On Mon, Jul 23, 2018 at 8:00 PM Manikumar wrote: > Hi all, > > I have created a KIP to use AdminClient API in AclCommand (kafka-acls.sh) > > > *https://cwiki.apache.org/confluence/display/KAFKA/KIP-332%3A+Update+AclCommand+to+use+AdminClient+API* > > &

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Hi Colin, Yes, "--authorizer-properties" option is not required with "--bootstrap-server" option. Updated the KIP. Thanks, On Tue, Jul 31, 2018 at 1:30 AM Ted Yu wrote: > Look good to me. > > On Mon, Jul 23, 2018 at 7:30 AM Manikumar > wrote: > > >

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Hi all, If there are no concerns, I will start the voting process soon. Thanks On Tue, Jul 31, 2018 at 9:08 AM Manikumar wrote: > Hi Colin, > > Yes, "--authorizer-properties" option is not required with > "--bootstrap-server" option. Updated the KIP. > >

[VOTE] KIP-332: Update AclCommand to use AdminClient API

/msg90049.html Thanks, Manikumar

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

no concerns, I will change the option to "--command-config". Since KIP-340 PR is not yet merged, we can also change there. Thanks, On Fri, Aug 3, 2018 at 1:57 PM Rajini Sivaram wrote: > Hi Manikumar, > > We have some tools already (ConfigCommand, ConsumerGroupCommand, > De

Re: [DISCUSS] KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

Hi Dong, In KIP-332 discussion, It was agreed to use "--command-config" option name for passing config property file. We can also use same name in here, to make it consistent across all tools. Thanks, On Thu, Jul 12, 2018 at 9:20 AM Dong Lin wrote: > wiki page is currently read-only and it i

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

Updated the KIP. added a note to KIP-340 discussion thread. On Fri, Aug 3, 2018 at 2:52 PM Rajini Sivaram wrote: > Thanks Manikumar. Can you add a note to the KIP-340 discussion thread? > > On Fri, Aug 3, 2018 at 10:04 AM, Manikumar > wrote: > > > Hi Rajini, > >

[DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Feedback and suggestions are welcome. Thanks Manikumar

Re: [DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

; So, it seems it's more consistent to pass in hmac as byte[] too. > 2. Does describeDelegationToken() return all tokens? > 3. As Ted mentioned, it would be useful to include the exceptions that can > be thrown in the new apis. > > Jun > > On Tue, Jan 16, 2018 at 10:03 AM

Re: [DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

stent to pass in hmac as byte[] too. > 2. Does describeDelegationToken() return all tokens? > 3. As Ted mentioned, it would be useful to include the exceptions that can > be thrown in the new apis. > > Jun > > On Tue, Jan 16, 2018 at 10:03 AM, Manikumar > wrote: > > >

Re: [DISCUSS] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Hi all, We want to include this KIP in the upcoming 1.1.0 release. Please let me know if there are any other comments. If there are no more comments, I'd like to start vote on this KIP. Thanks, On Wed, Jan 17, 2018 at 8:20 AM, Manikumar wrote: > Hi, Jun, > > Thanks for the

[VOTE] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Hi All, I would like to start a vote on KIP-249 which would add delegation token operations to Java Admin Client. We have merged DelegationToken API PR recently. We want to include admin client changes in the upcoming release. This will make the feature complete. https://cwiki.apache.org/conflue

Re: [VOTE] KIP-86: Configurable SASL callback handlers

Hi, +1 (non-binding) Thanks for the KIP. On Wed, Jan 24, 2018 at 5:00 AM, Jun Rao wrote: > Hi, Rajini, > > Thanks for the KIP. +1 from me. > > Jun > > On Thu, Jan 18, 2018 at 8:58 AM, tao xiao wrote: > > > +1 (non-binding) > > > > On Fri, 19 Jan 2018 at 00:47 Rajini Sivaram > > wrote: > > >

Re: [VOTE] KIP-206: Add support for UUID serialization and deserialization

+1 (non-binding) On Tue, Jan 30, 2018 at 11:50 AM, Ewen Cheslack-Postava wrote: > +1 (binding) > > On Fri, Jan 26, 2018 at 9:16 AM, Colin McCabe wrote: > > > +1 (non-binding) > > > > > > > > On Fri, Jan 26, 2018, at 08:29, Ted Yu wrote: > > > +1 > > > > > > On Fri, Jan 26, 2018 at 7:00 AM, Bran

Re: [DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

Hi, 1. Do we support IPv6 CIDR/ranges? 2. KAFKA-5713 is mentioned in Related JIRAs section. But there is no mention of wildcard support in the KIP. Thanks, On Thu, Feb 1, 2018 at 4:05 AM, Sönke Liebau < soenke.lie...@opencore.com.invalid> wrote: > Hey everybody, > > following a brief inital d

Re: [DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

n Thu, Feb 1, 2018 at 5:56 PM, Sönke Liebau < soenke.lie...@opencore.com.invalid> wrote: > Hi Manikumar, > > the current proposal indeed leaves out IPv6 addresses, as I was unsure > whether Kafka fully supports that yet to be honest. But it would be > fairly easy to add these to

Re: Kafka Log deletion Problem

looks like log segment is not rotated. You can send more data or adjust log.roll.ms/log.segment.bytes configs to rotate segments. On Fri, Feb 2, 2018 at 7:08 PM, SenthilKumar K wrote: > Hello Experts , We have a Kafka Setup running for our analytics pipeline > ...Below is the broker config ..

Re: [VOTE] 1.0.1 RC2

+1 (non-binding) Built src and ran tests Ran core quick start On Sat, Feb 24, 2018 at 8:44 PM, Jakub Scholz wrote: > +1 (non-binding) ... I used the Scala 2.12 binaries and run my tests with > producers / consumers. > > On Thu, Feb 22, 2018 at 1:06 AM, Ewen Cheslack-Postava > wrote: > > > Hello

Re: [DISCUSS] KIP-272: Add API version tag to broker's RequestsPerSec metric

Can we retain total RequestsPerSec metric and add new version tag metric? When monitoring with simple jconsole/jmx based tools, It is useful to have total metric to monitor request rate. Thanks, On Wed, Mar 21, 2018 at 11:01 AM, Gwen Shapira wrote: > I love this. Not much to add - it is an ele

Re: Producer timeout and retry behavior

Hi, a) If there are no brokers available, producer send() will block up to max_block_ms (default: 6) after which it will throw a TimeoutException. No retries in this case. by-default console producer uses Callback and just logs the error after max_block_ms. b) Current behavior is, If

Re: [kafka-clients] Re: [VOTE] 1.1.0 RC4

+1 (non-binding) - Verified src, binary artifacts and basic quick start - Verified delegation token operations and docs - Verified dynamic broker configuration and docs. On Tue, Mar 27, 2018 at 6:52 PM, Rajini Sivaram wrote: > Can we get some more votes for this RC so that the release can be r

Re: [ANNOUNCE] Apache Kafka 1.1.0 Released

ines that reliably get data > >> > >> between systems or applications. > >> > >> > >> > >> ** Building real-time streaming applications that transform or react to > the > >> > >> streams of data. > >> > >>

Re: [VOTE] KIP-249: Add Delegation Token Operations to Kafka Admin Client

> > Jun > > > > On Sun, Jan 21, 2018 at 7:44 AM, Manikumar > > wrote: > > > > > Hi All, > > > > > > I would like to start a vote on KIP-249 which would add delegation > token > > > operations > > > to Java Admin Client. > &

Re: [VOTE] KIP-272: Add API version tag to broker's RequestsPerSec metric

+1 (non-binding) On Thu, Mar 29, 2018 at 6:16 PM, Thomas Crayford wrote: > +1 (non-binding) > > On Wed, Mar 28, 2018 at 9:15 PM, Ted Yu wrote: > > > +1 > > > > On Wed, Mar 28, 2018 at 12:05 PM, Mickael Maison < > mickael.mai...@gmail.com > > > > > wrote: > > > > > +1 (non binding) > > > Thanks

Re: [VOTE] KIP-249: Add Delegation Token Operations to Kafka Admin Client

Hi All, The vote has passed with 3 binding votes (Jun, Gwen, Rajini) and 2 non-binding votes (Satish, Viktor). Thanks everyone for the votes. Thanks, Manikumar On Tue, Apr 3, 2018 at 2:46 PM, Rajini Sivaram wrote: > +1 (binding) > > Thanks for the KIP, Manikumar! > > On Thu,

Re: [DISCUSS] KIP-269: Substitution Within Configuration Values

Hi, Substitution mechanism can be useful to configure regular password configs liken ssl.keystore.password, ssl.truststore.password, etc. This is can be good alternative to previously proposed KIP-76 and will give more options to the user. https://cwiki.apache.org/confluence/display/KAFKA/KIP- 76

Re: [VOTE] KIP-211: Revise Expiration Semantics of Consumer Group Offsets

+1 (non-binding) Thanks for the detailed KIP. On Fri, Apr 6, 2018 at 8:54 AM, Guozhang Wang wrote: > Thanks for the KIP! > > +1 (binding) > > On Thu, Apr 5, 2018 at 3:11 PM, Matthias J. Sax > wrote: > > > +1 (binding) > > > > > > -Matthias > > > > On 4/5/18 4:36 AM, Ted Yu wrote: > > > +1 > >

Re: [DISCUSS] KIP-269: Substitution Within Configuration Values

> > > >>> need to > > > > > > > >>>worry about the latter if substitutions are only by > opt-in. > > > > > > > >>>- It will be good to get more feedback on this KIP > before > > > > &

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non-binding). Thanks. On Thu, Apr 19, 2018 at 3:07 PM, Stephane Maarek < steph...@simplemachines.com.au> wrote: > +1 (non binding). Thanks Ismael! > > On Thu., 19 Apr. 2018, 2:47 pm Gwen Shapira, wrote: > > > +1 (binding) > > > > On Wed, Apr 18, 2018 at 11:35 AM, Ismael Juma wrote: > > > >

Re: [VOTE] KIP-282: Add the listener name to the authentication context

+1 (non-binding) On Wed, Apr 25, 2018 at 9:05 PM, Ted Yu wrote: > +1 > > On Wed, Apr 25, 2018 at 8:33 AM, Rajini Sivaram > wrote: > > > Hi Mickael, > > > > Thanks for the KIP. > > > > +1 (binding) > > > > On Wed, Apr 25, 2018 at 9:51 AM, Mickael Maison < > mickael.mai...@gmail.com> > > wrote: >

Re: [VOTE] KIP-277 - Fine Grained ACL for CreateTopics API

+1 (non-binding) Thanks On Thu, Apr 26, 2018 at 9:59 PM, Colin McCabe wrote: > +1 (non-binding) > > best, > Colin > > > On Wed, Apr 25, 2018, at 02:45, Edoardo Comar wrote: > > Hi, > > > > The discuss thread on KIP-277 ( > > https://www.mail-archive.com/dev@kafka.apache.org/msg86540.html ) > >

Re: [DISCUSS] KIP-278: Add version option to Kafka's commands

I assume the intent of the KIP to find out the Kafka broker version. In this case, maybe we should expose version using a Kafka request. This will help the remote scripts/tools to query the Kafka version. scripts (kafka-topics.sh, kafka-configs.sh, etc..) may run from remote machines and may use

Re: [DISCUSS] KIP-278: Add version option to Kafka's commands

d, we can implement this in future. Thanks, On Wed, May 2, 2018 at 10:58 PM, Colin McCabe wrote: > Hi Manikumar, > > We already have a tool for getting the Kafka broker API versions, > "./bin/kafka-broker-api-versions.sh". It was added as part of KIP-97. > > What Sa

Re: [VOTE] KIP-332: Update AclCommand to use AdminClient API

Hi All, The vote has passed with 3 binding votes (Rajini, Jason, Dong) and 2 non-binding votes (Ted, Colin). Thanks everyone for the votes. Thanks, Manikumar On Sat, Aug 4, 2018 at 5:09 AM Dong Lin wrote: > Thanks Manikumar! > > +1 > > On Fri, Aug 3, 2018 at 4:33 PM,

Re: [DISCUSS] KIP-332: Update AclCommand to use AdminClient API

ile" > > StreamsResetter. I will let others comment on whether we should change to > > this when we add the option to other tools. > > > > Regards, > > > > Rajini > > > > On Fri, Aug 3, 2018 at 5:41 PM, Dong Lin wrote: > > > > > Hey

Re: [VOTE] KIP-346 - Improve LogCleaner behavior on error

+1 (non-binding) Thanks for the KIP. On Tue, Aug 7, 2018 at 10:42 PM Ray Chiang wrote: > +1 (non-binding) > > -Ray > > On 8/7/18 9:26 AM, Ted Yu wrote: > > +1 > > > > On Tue, Aug 7, 2018 at 5:25 AM Thomas Becker > wrote: > > > >> +1 (non-binding) > >> > >> We've hit issues with the log cleaner

Re: [VOTE] KIP-289: Improve the default group id behavior in KafkaConsumer

+1 (non-binding). Thanks for the KIP. On Wed, Aug 8, 2018 at 7:36 PM Ted Yu wrote: > +1 > > On Wed, Aug 8, 2018 at 4:09 AM Mickael Maison > wrote: > > > +1 (non-binding) > > Thanks Vahid > > On Wed, Aug 8, 2018 at 11:26 AM Kamal Chandraprakash > > wrote: > > > > > > +1 (non-binding) > > > > >

Re: Java 11 support

check this: https://issues.apache.org/jira/browse/KAFKA-7264 On Thu, Aug 16, 2018 at 2:40 PM Manoj Jain wrote: > Hi All, > > I have just subscribed to this group. I don't know what is format of > questions to be submitted yet but in hurry thought of getting more details > on kafka java support

[DISCUSS] KIP-357: Add support to list ACLs per principal

Hi all, I have created a minor KIP to add support to list ACLs per principal using AclCommand (kafka-acls.sh) https://cwiki.apache.org/confluence/display/KAFKA/KIP-357%3A++Add+support+to+list+ACLs+per+principal Please take a look. Thanks,

  1   2   3   4   5   6   7   8   9   10   >