Hey Alex, Conceptually you aren't sending a single message to all topics, but to be available in all partitions you'd have to send a message for each partition. You can fan out in the client like this though: https://gist.github.com/anonymous/92bb8b788742e95ee2e8
Best, Mike On Sat, Mar 7, 2015 at 5:55 PM, Alex Melville <amelvi...@g.hmc.edu> wrote: > Hello, > > 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, > > Alex
