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
- how to get topic names in SinkFunction when using Flin... Richard Xin
- Re: how to get topic names in SinkFunction when u... Tzu-Li (Gordon) Tai
- Re: how to get topic names in SinkFunction wh... Richard Xin
- Re: how to get topic names in SinkFunctio... Tzu-Li (Gordon) Tai