Re: [ANNOUNCE] New committer: Onur Karaman

gt; > > > On Nov 6, 2017, at 9:24 AM, Jun Rao <j...@confluent.io> wrote: > > > > > > Hi, everyone, > > > > > > The PMC of Apache Kafka is pleased to announce a new Kafka committer > Onur > > > Karaman. > > > > > > Onur's

Re: [DISCUSS] KIP-213 Support non-key joining in KTable

Looks like Jan technically made his KIP wiki page first so I'll just change my KIP number. On Wed, Oct 25, 2017 at 4:59 PM, Matthias J. Sax wrote: > Thanks a lot for the KIP. Can we please move the discussion to the dev > list? > > Thus, after fixing the KIP collision,

Re: [DISCUSS] KIP-175: Additional '--describe' views for ConsumerGroupCommand

In other words, I think the default should be the exact behavior we have today plus the remaining group information from DescribeGroupResponse. On Fri, Jul 14, 2017 at 11:36 AM, Onur Karaman <onurkaraman.apa...@gmail.com > wrote: > I think if we had the opportunity to start fro

Re: [DISCUSS] KIP-175: Additional '--describe' views for ConsumerGroupCommand

I think if we had the opportunity to start from scratch, --describe would have been the following: --describe --offsets: shows all offsets committed for the group as well as lag --describe --state (or maybe --members): shows the full DescribeGroupResponse output (including things like generation

Re: stunning error - Request of length 1550939497 is not valid, it is larger than the maximum size of 104857600 bytes

@James: that was incredible. Thank you. On Wed, Apr 26, 2017 at 9:53 PM, James Cheng wrote: > Ramya, Todd, Jiefu, David, > > Sorry to drag up an ancient thread. I was looking for something in my > email archives, and ran across this, and I might have solved part of these >

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congrats! On Mon, Apr 24, 2017 at 2:20 PM, Guozhang Wang wrote: > Congrats Rajini! > > Guozhang > > On Mon, Apr 24, 2017 at 2:08 PM, Vahid S Hashemian < > vahidhashem...@us.ibm.com> wrote: > > > Great news. > > > > Congrats Rajini! > > > > --Vahid > > > > > > > > > > From:

Re: Re: ZK and Kafka failover testing

If this is what I think it is, it has nothing to do with acks, max.in.flight.requests.per.connection, or anything client-side and is purely about the kafka cluster. Here's a simple example involving a single zookeeper instance, 3 brokers, a KafkaConsumer and KafkaProducer (neither of these

Re: How does one deploy to consumers without causing re-balancing for real time use case?

at 10:22 AM, Praveen <praveev...@gmail.com> wrote: > >> I still think a clean cluster start should not take > 1 hr for balancing >> though. Is this expected or am i doing something different? >> >> I thought this would be a common use case. >> >> P

Re: How does one deploy to consumers without causing re-balancing for real time use case?

Pradeep is right. close() will try and send out a LeaveGroupRequest while a kill -9 will not. On Fri, Feb 10, 2017 at 10:19 AM, Pradeep Gollakota wrote: > I believe if you're calling the .close() method on shutdown, then the > LeaveGroupRequest will be made. If you're

Re: KIP-122: Add a tool to Reset Consumer Group Offsets

I think it makes sense to just add the feature to kafka-consumer-groups.sh On Tue, Feb 7, 2017 at 10:24 PM, Gwen Shapira wrote: > Thanks for the KIP. I'm super happy about adding the capability. > > I hate the interface, though. It looks exactly like the replica > assignment

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

+1 On Wed, Jan 11, 2017 at 11:06 AM, Jason Gustafson wrote: > +1 > > On Wed, Jan 11, 2017 at 10:56 AM, Ben Stopford wrote: > > > Looks like there was a good consensus on the discuss thread for KIP-106 > so > > lets move to a vote. > > > > Please chime in

Re: [ANNOUNCE] New committer: Jiangjie (Becket) Qin

Congrats Becket! On Mon, Oct 31, 2016 at 10:35 AM, Joel Koshy wrote: > The PMC for Apache Kafka has invited Jiangjie (Becket) Qin to join as a > committer and we are pleased to announce that he has accepted! > > Becket has made significant contributions to Kafka over the

Re: [ANNOUNCE] New committer: Jason Gustafson

congrats jason! On Tue, Sep 6, 2016 at 4:12 PM, Sriram Subramanian wrote: > Congratulations Jason! > > On Tue, Sep 6, 2016 at 3:40 PM, Vahid S Hashemian < > vahidhashem...@us.ibm.com > > wrote: > > > Congratulations Jason on this very well deserved recognition. > > > >

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

There's also a concurrency bug in the GroupMetadataManager that we'd probably want fixed before the 0.9.0.0 release that Jason / Guozhang is working on: https://issues.apache.org/jira/browse/KAFKA-2795 On Tue, Nov 10, 2015 at 11:39 AM, Jun Rao wrote: > Ewen, > > Thanks for

Re: 0.9.0 release branch

I added KAFKA-2698 as an 0.9.0.0 blocker. It adds an API to query the currently paused partitions. Here's the PR: https://github.com/apache/kafka/pull/403 On Mon, Nov 2, 2015 at 11:16 AM, Cliff Rhyne wrote: > Hi Jun, > > I