kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alex Melville <amelvi...@g.hmc.edu>
Subject How To Push Message to Every Partition On A Topic
Date Sat, 07 Mar 2015 22:55:44 GMT

Note I am using the new 0.8.2 version of Kafka and so I'm using the new
KafkaProducer class.

I have a special type of message data that I need to push to every
partition in a topic. Can that be done with custom partitioner that
implements Partitioner when Partitioner expects you to return just a single
partition? If not, how can I implement in my Java code a send() method that
sends a message to every partition?

Thank you in advance,


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message