2016-04-27 10 views
1

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))); 

    } 

Antwort

2

entnehmen Sie bitte senden Sie es an derselben Partition gesendet werden.

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

} 

Ich habe die Nachricht randomisiert durch

+0

-"message"+i Ändern Danke, ich habe –

Verwandte Themen