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

Reply via email to