Re: Partition assignment in kafka streams

Hi All,

The main reason for knowing the partitions is to have a localized routing
based on partitions assigned to set a stream tasks. This would really help
in my use case.

Thanks

On Mon, Jul 29, 2019 at 8:58 PM Navneeth Krishnan <reachnavneeth2@gmail.com>
wrote:

> Hi,
>
> I'm using the processor topology for my use case and I would like to get
> the partitions assigned to a particular stream instance. I looked at the
> addSouce function but I don't see a way to add a callback to get notified
> when partition assignment or reassignment happens. Please advise.
>
> Thank you
>