Hi all, I am building an application that launches Flink Jobs and monitors them.
I want to use the JobListener interface to output job evemts to a Kafka Topic. The problem: In the application we have RuleId, i.e. business logic identifier for the job, and there’s JobId which is the internal identifier generated by Flink. I need the events emitted to Kafka to be partitioned by *RuleId*. Is there a way to pass this kind of information to Flink and get it through the JobListener interface? Thanks, Barak
