pulsar-flink
pulsar-flink copied to clipboard
[Feature] Support for exposing key and event_time columns when reading data from pulsar
We need to find a way to return the row with additional pulsar message's metadata columns to help user do some queries based on these meta information