Partition assignment in kafka streams

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