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
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