Hello,
We need to publish heartbeat messages in all topic partitions. Is possible to 
produce single message and then somehow broadcast it to all partitions from 
FlinkKafkaProducer? Or only way that message source knows number of existing 
partitions and sends 1 message to 1 partition?

Thanks,
Alexey

Reply via email to