Re: Different deserialization schemas for Kafka keys and values

2020-08-27 Thread Manas Kale
Hi Robert, Thanks for the info! On Thu, Aug 27, 2020 at 8:01 PM Robert Metzger wrote: > Hi, > > Check out the KafkaDeserializationSchema ( > https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/connectors/kafka.html#the-deserializationschema) > which allows you to deserialize the key

Re: Different deserialization schemas for Kafka keys and values

2020-08-27 Thread Robert Metzger
Hi, Check out the KafkaDeserializationSchema ( https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/connectors/kafka.html#the-deserializationschema) which allows you to deserialize the key and value bytes coming from Kafka. Best, Robert On Thu, Aug 27, 2020 at 1:56 PM Manas Kale wr