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 a
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
