I have Flink DataStream job that flows like this: before DataStream definition define list of Kafka Topics