flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Richard Xin <richardxin...@yahoo.com>
Subject how to get topic names in SinkFunction when using FlinkKafkaConsumer010 with multiple topics
Date Thu, 06 Jul 2017 01:05:17 GMT
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
Mime
View raw message