Re: Very long consumer rebalances

2018-08-10 Thread Puneet Saha
Please remove me from the list On Fri, Jul 6, 2018 at 2:55 AM Shantanu Deshmukh wrote: > Hello everyone, > > We are running a 3 broker Kafka 0.10.0.1 cluster. We have a java app which > spawns many consumer threads consuming from different topics. For every > topic we have specified different

Re: Requesting for JIRA permission as contributor/committer

2018-08-10 Thread Manjunath N
Hi Guozhang, Could please add manj...@gmail.com too. So that i can take up some open issues to contribute. Thanks Manjunath > On Aug 10, 2018, at 9:13 PM, Guozhang Wang wrote: > > It's done. > > Cheers, > Guozhang > > On Fri, Aug 10, 2018 at 6:34 AM, M. Manna

Re: Requesting for JIRA permission as contributor/committer

2018-08-10 Thread Guozhang Wang
Done. Guozhang On Fri, Aug 10, 2018 at 9:48 AM, Manjunath N wrote: > Hi Guozhang, > > Could please add manj...@gmail.com too. So > that i can take up some open issues to contribute. > > Thanks > Manjunath > > > On Aug 10, 2018, at 9:13 PM, Guozhang Wang wrote: > >

Re: Requesting for JIRA permission as contributor/committer

2018-08-10 Thread Guozhang Wang
It's done. Cheers, Guozhang On Fri, Aug 10, 2018 at 6:34 AM, M. Manna wrote: > manmedia - (email - manme...@gmail.com) > > On 10 August 2018 at 14:34, Guozhang Wang wrote: > > > Hello, > > > > What is your apache id? > > > > > > Guozhang > > > > On Fri, Aug 10, 2018 at 12:50 AM, M. Manna

Requesting for JIRA permission as contributor/committer

2018-08-10 Thread M. Manna
Hello, Is it possible to get permission for assigning JIRA tickets. Just wanted to start with some minor bugs/features. Regards,

Re: Very long consumer rebalances

2018-08-10 Thread M. Manna
if you can upgrade, I would say upgrading to 0.10.2.x would be better for you (or even higher, 2.0.0). Otherwise you have to play around with max.poll.records and session.timeout.ms. As the doc says (or newer versions), the adjustment should be such that request.timeout.ms >=

Usage of cleanup.policy=compact,delete

2018-08-10 Thread Patrik Kleindl
Hello In a discussion yesterday the question came up if an internal changelog topic can be enabled for compaction and deletion. https://stackoverflow.com/questions/50622369/kafka-streams-is-it-possible-to-have-compact-delete-policy-on-state-stores and

Re: Very long consumer rebalances

2018-08-10 Thread Shantanu Deshmukh
All this is fine. But what I do not understand is, why only some of the consumer groups start very late. We have 7 topics and their consumers belong to 7 different CGs. Whenever I want to restart my application Only one or two of them will start very late. It takes almost 5-10 minutes before their

Re: Requesting for JIRA permission as contributor/committer

2018-08-10 Thread Guozhang Wang
Hello, What is your apache id? Guozhang On Fri, Aug 10, 2018 at 12:50 AM, M. Manna wrote: > Hello, > > Is it possible to get permission for assigning JIRA tickets. Just wanted to > start with some minor bugs/features. > > Regards, > -- -- Guozhang

Re: Requesting for JIRA permission as contributor/committer

2018-08-10 Thread M. Manna
manmedia - (email - manme...@gmail.com) On 10 August 2018 at 14:34, Guozhang Wang wrote: > Hello, > > What is your apache id? > > > Guozhang > > On Fri, Aug 10, 2018 at 12:50 AM, M. Manna wrote: > > > Hello, > > > > Is it possible to get permission for assigning JIRA tickets. Just wanted > to