Thank you for your question. I responded on StackOverflow.
Let's finish the discussion there.
On Fri, Jul 24, 2020 at 5:07 AM Vijayendra Yadav
wrote:
> Hi Flink Team,
>
> *FLINK Streaming:* I have DataStream[String] from kafkaconsumer
>
> DataStream stream = env
> .addSource(new FlinkKafkaCo
Hi Flink Team,
*FLINK Streaming:* I have DataStream[String] from kafkaconsumer
DataStream stream = env
.addSource(new FlinkKafkaConsumer<>("topic", new
SimpleStringSchema(), properties));
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html
I have to sink this st
