Hi All,

Is it possible to have a tracking id in MDC that will be shared across
chained users defined operations like Filter, KeySelector, Flat map,
Process function, and  Producer?

Tracking id will be read from headers of Kafka Message, which if possible
plan to set to MDC in log4j. Right now I am seeing tracking id is not
getting propagated to the next function.

I am using flink 1.9 running in k8.

Thanks, Anil

Reply via email to