Anyone would like to give some help? Can't send a keyedMessage to brokers with
partitioner.class=kafka.producer.DefaultPartitioner
| |
| | | | | | | |
| Can't send a keyedMessage to brokers with partitioner.cl...I have a 2 nodes
kafka cluster with 2 instances of brokers
Hi,I have a 2 nodes kafka cluster with 2 instances of brokers and zookeepers.
And then I create a topic kafka-test with 2 partitions and replication-factor
=2. My producer config is: {partitioner.class
kafka.producer.DefaultPartitioner
