Ich bin neu bei kafka.Ich lese den schnellen Start und erstellen Sie ein Thema namens "test" mit 4 Partitionen, aber beim Senden von Nachrichten an das Thema finde ich alle Nachrichten in der Partition gespeichert sind -0, die anderen drei Partitionen sind leer warum?kafka multi-partition nur einer kann Nachricht empfangen
gibt es mein Java-Code-Nachrichten an die javadoc
If no partition is specified but a key is present a partition will be chosen using a hash of the key.
Da Sie den gleichen Schlüssel sind vorbei, wird
for (int i = 0; i < 100; i++){
producer.send(new ProducerRecord<String, String>("test", "message",Integer.toString(i)));
}
-
"message"+i
Ändern Danke, ich habe –