Hello, I have a scenario like for kafka source where kafka headers also come along with kafka record/event. Kafka headers fetched need to share/pass to next/parallel operators in pipeline.
So, is there any way to share data across operator pipeline? Explored keyed state which has limitation that only with keyby() it will work. Explored broadcast state which limitation that it can only work with process functions and not with map/flatmap/filter etc. Rgds, Kamal
