Hello, I have requirement to connect multiple kafka sources, say topic1, topic2 initially I have built kafkaSourceBuilder where I passed above 2 topics to setTopics method Everything works good till here My source topics are dynamic in nature, I have updated topics to Topic1 and Topic3 Datastream is now connected to Topic1 and Topic3 but at the same time it is still connected to Topic2 which is not expected

My source topics are dynamic in nature,

That's currently not supported until https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217389320