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
