Adding Kafka topics to a running streaming context

[yael aharon]

Hello,
My streaming application needs to allow consuming new Kafka topics at
arbitrary times. I know I can stop and start the streaming context when I
need to introduce a new stream, but that seems quite disruptive. I am
wondering if other people have this situation and if there is a more
elegant solution?
thanks, Yael