___
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
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
...@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
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
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
__
>
> 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
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
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@
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
;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
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.
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
. 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
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: &
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
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
16 matches
Mail list logo