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" "metadata.broker.list"
"172.32.1.248:9092,172.32.1.251:9092"
"request.required.acks" "1"}
So for the DefaultPartitoner, it will calculate and hashvalue and divide by the
num_partiton to decide which partition the data it will go, so I create my
keyedMessageval key-msg = KeyedMessage("kafka-test","a","test
message!")prod.send(key-msg)
"a"'s hashValue is 97 and 97 % 2 = 1, so the data should go to partition1.
However, the data did't get send to the brokers (I have a console consumer
running that didn't receive any message from this topic). If I create the
key-msg without the key, it works fine
val key-msg = KeyedMessage("kafka-test","test message!")prod.send(key-msg)
Am I using the key wrong or anything?ThanksEdwin
