Thanks, I'll try that.
On Wed, Dec 7, 2022 at 7:19 PM Yaroslav Tkachenko <yaros...@goldsky.com> wrote: > > 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