You cannot hook into partition assignment, and I am not sure what you exactly want to do.
You can get local assignment metadata via `KafkaStreams#localThreadMetadata()` though. Hope this helps. -Matthias On 7/29/19 11:29 PM, Navneeth Krishnan wrote: > 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 >> >
signature.asc
Description: OpenPGP digital signature
