Thank You Roman. There is one more: env.*setStateBackend* Deprecated: setStateBackend from *org.apache.flink.streaming.api.scala*
Regards, Vijay On Mon, Aug 3, 2020 at 9:21 AM Khachatryan Roman < [email protected]> wrote: > 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 <[email protected]> > 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 >> >
