Hi Vijay, The javadoc for org.apache.flink.streaming.util.serialization.SimpleStringSchema says you should Use org.apache.flink.api.common.serialization.SimpleStringSchema instead.
Regards, Roman On Mon, Aug 3, 2020 at 5:31 PM Vijayendra Yadav <contact....@gmail.com> wrote: > Hi Team, > > > https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html > > new SimpleStringSchema() --> Is showing Deprecated in my IntelliJ. > Although it's working fine, Wanted to check if there is a replacement for > it ? > > > > val properties = new Properties() > properties.setProperty("bootstrap.servers", "localhost:9092") > properties.setProperty("group.id", "test") > stream = env > .addSource(new FlinkKafkaConsumer[String]("topic", new > SimpleStringSchema(), properties)) > > Regards, > Vijay >
