Hi Alexey,
I don't see a way to do it with one message in FlinkKafkaProducer. So you
have to multiply the heartbeat yourself. I'd imagine the easiest way would
be to query the number of partitions of the output topic (it's static in
Kafka) in the heartbeat producer and already produce as all
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,
