As per this link, it says that it only supports value_only for now as I am using pyflink. Does it mean I can't extract the timestamp appended by Kafka with pyflink as of now?
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/kafka/#deserializer or does it mean something else? Thanks. On Mon, Oct 2, 2023 at 4:32 PM Perez <flinkbyhe...@gmail.com> wrote: > Hi Liu and Jinfeng, > > I am trying to implement KafkaDeserializationSchema for Pyflink but am > unable to get any examples. Can you share some links or references using > which I can understand and try to implement myself? > > Perez sid. >
