Hi Anil,
Flink does not maintain the MDC context between threads. Hence, I don't
think that it is possible w/o changes to Flink.
One note, if operators are chained then they are run by the same thread.
Cheers,
Till
On Wed, Dec 2, 2020 at 7:22 AM Anil K wrote:
> Hi All,
>
> Is it possible to h
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 a
