Hi Noel, It's definitely possible. You need to implement a custom KafkaRecordDeserializationSchema: its "deserialize" method gives you a ConsumerRecord as an argument so that you can extract Kafka message key, headers, timestamp, etc.
Then pass that when you create a KafkaSource via "setDeserializer" method. On Wed, Dec 7, 2022 at 6:14 AM Noel OConnor <noel.ocon...@gmail.com> wrote: > Hi, > I'm using a kafka source to read in messages from kafka into a datastream. > However I can't seem to access the key of the kafka message in the > datastream. > Is this even possible ? > > cheers > Noel >
