flink-streaming-confluent DeserializationSchema compatible with Confluent's KafkaAvroDecoder JVM variants Java Scala