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 <reachnavnee...@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 >
