Re: more uniform task assignment across kafka stream nodes

2017-03-28 Thread Ara Ebrahimi
___ From: "Matthias J. Sax" mailto:matth...@confluent.io><mailto:matth...@confluent.io>> Subject: Re: more uniform task assignment across kafka stream nodes Date: March 27, 2017 at 4:15:07 PM PDT To: users@kafka.apache.org<mailto:users@k

Re: more uniform task assignment across kafka stream nodes

2017-03-28 Thread Matthias J. Sax
tely and delete the original. Any > other use of the e-mail by you is prohibited. Thank you in advance for your > cooperation. > > ____ > > From: "Matthias J. Sax" mailto:matth...@confluent.io>> > Subject: Re: more un

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Ara Ebrahimi
...@confluent.io>> Subject: Re: more uniform task assignment across kafka stream nodes Date: March 27, 2017 at 4:15:07 PM PDT To: users@kafka.apache.org<mailto:users@kafka.apache.org> Reply-To: mailto:users@kafka.apache.org>> Great! So overall, the issue is not related to task assignment

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Matthias J. Sax
immediately and delete the original. Any > other use of the e-mail by you is prohibited. Thank you in advance for your > cooperation. > > ____________ > > From: "Matthias J. Sax" mailto:matth...@confluent.io>> > Subject: Re

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Ara Ebrahimi
you is prohibited. Thank you in advance for your cooperation. From: "Matthias J. Sax" mailto:matth...@confluent.io>> Subject: Re: more uniform task assignment across kafka stream nodes Date: March 27, 2017 at 2:41:06 PM PDT To: users@kafka.apache.org<mail

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Ara Ebrahimi
__ > > This message is for the designated recipient only and may contain > privileged, proprietary, or otherwise confidential information. If you have > received it in error, please notify the sender immediately and delete the > original. Any other use of the e-mail by you is prohi

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Matthias J. Sax
t; other use of the e-mail by you is prohibited. Thank you in advance for your > cooperation. > > > > From: "Matthias J. Sax" mailto:matth...@confluent.io>> > Subject: Re: more uniform task assignment across kafka stream nodes > Da

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Damian Guy
the e-mail by you is prohibited. Thank you in advance for your cooperation. From: "Matthias J. Sax" mailto:matth...@confluent.io >> Subject: Re: more uniform task assignment across kafka stream nodes Date: March 27, 2017 at 1:35:30 PM PDT To: users@

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Ara Ebrahimi
From: "Matthias J. Sax" mailto:matth...@confluent.io>> Subject: Re: more uniform task assignment across kafka stream nodes Date: March 27, 2017 at 1:35:30 PM PDT To: users@kafka.apache.org<mailto:users@kafka.apache.org> Reply-To: mailto:users@kafka.apache.org>> Ara, t

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Matthias J. Sax
;mailto:users@kafka.apache.org> > Reply-To: > mailto:users@kafka.apache.org><mailto:users@kafka.apache.org>> > > > Ara, > > How do you consume your topics? Via > > builder.stream("topic1", "topic2", "topic3); > > or via

Re: more uniform task assignment across kafka stream nodes

2017-03-27 Thread Ara Ebrahimi
in error, please notify the sender immediately and delete the original. Any other use of the e-mail by you is prohibited. Thank you in advance for your cooperation. From: "Matthias J. Sax" mailto:matth...@confluent.io><mailto:matth...@confluent.

Re: more uniform task assignment across kafka stream nodes

2017-03-25 Thread Matthias J. Sax
dvance for your > cooperation. > > ____________ > > From: "Matthias J. Sax" mailto:matth...@confluent.io>> > Subject: Re: more uniform task assignment across kafka stream nodes > Date: March 25, 2017 at 6:04:30 PM PDT > To: users@kafka.ap

Re: more uniform task assignment across kafka stream nodes

2017-03-25 Thread Ara Ebrahimi
. Thank you in advance for your cooperation. From: "Matthias J. Sax" mailto:matth...@confluent.io>> Subject: Re: more uniform task assignment across kafka stream nodes Date: March 25, 2017 at 6:04:30 PM PDT To: users@kafka.apache.org<mai

Re: more uniform task assignment across kafka stream nodes

2017-03-25 Thread Matthias J. Sax
confidential information. If you have received it > in error, please notify the sender immediately and delete the original. Any > other use of the e-mail by you is prohibited. Thank you in advance for your > cooperation. > > ____ > > From: &

Re: more uniform task assignment across kafka stream nodes

2017-03-25 Thread Ara Ebrahimi
sender immediately and delete the original. Any other use of the e-mail by you is prohibited. Thank you in advance for your cooperation. From: "Matthias J. Sax" mailto:matth...@confluent.io>> Subject: Re: more uniform task assignment across kafka st

Re: more uniform task assignment across kafka stream nodes

2017-03-25 Thread Matthias J. Sax
Hi, I am wondering why this happens in the first place. Streams, load-balanced over all running instances, and each instance should be the same number of tasks (and thus partitions) assigned. What is the overall assignment? Do you have StandyBy tasks configured? What version do you use? -Matthi