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
