Hi community, I'm testing out 1.12-SNAPSHOT in master branch I built my application with library 'flink-connector-kafka' but when I start the app, I get
Caused by: org.apache.kafka.common.KafkaException: class org.apache.kafka.common.serialization.ByteArrayDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer while constructing KafkaConsumer class. Is this normal behavior?
