Flink – error: ByteArrayDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer I am running a Flink job locally using
