Hi, For a Flink batch job, some value are writing to Kafka through a Producer.
I want to register a hook for closing (at the end) the Kafka producer a worker is using.... hook to be executed, of course, on worker side. Is there a way to do so ? Thanks. Regards, Dominique