kafkaマルチパーティションのみがメッセージを受け取ることができます

Question

私はkafkaを初めて使っています。クイックスタートを読み、4つのパーティションで 'test'という名前のトピックを作成しましたが、 -0、他の3つのパーティションは空なぜですか？あなたは同じキーを渡しているので

私のJavaコードはメッセージ

for (int i = 0; i < 100; i++){ 
     producer.send(new ProducerRecord<String, String>("test", "message",Integer.toString(i))); 

    } 

Answer 1

を送信することがありjavadoc

If no partition is specified but a key is present a partition will be chosen using a hash of the key.

を参照してください、それは同じパーティションに送信されています。

for (int i = 0; i < 100; i++){ 
    producer.send(new ProducerRecord<String, String>("test", "message"+i,Integer.toString(i))); 

} 

私は私が持っている、ありがとう"message"+i