when using FlinkKafkaConsumer010 to subscribing multiple topics as 
List<String> topics = Arrays.asList("test1","test2");
DataStream<String> stream = env.addSource(new FlinkKafkaConsumer010<>(topics, 
new SimpleStringSchema(), properties));
How do I get topic names in my SinkFunction? i.e. stream.addSink()
Thanks,Richard

Reply via email to