... | @@ -102,7 +102,7 @@ Pour contrer ça et lire d'un coup tous les messages envoyés par le producer, o |
... | @@ -102,7 +102,7 @@ Pour contrer ça et lire d'un coup tous les messages envoyés par le producer, o |
|
|
|
|
|
`./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning`
|
|
`./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning`
|
|
|
|
|
|
Tester la lecture sur un nombre fixe de messages
|
|
Tester la lecture sur un nombre fixe de messages (ici 11 messages sur le topic "test")
|
|
`./kafka_2.10-0.10.2.1/bin/kafka-simple-consumer-shell.sh --broker-list trueack.ovh:9092 --offset -2 --max-messages 11 --partition 0 --topic test`
|
|
`./kafka_2.10-0.10.2.1/bin/kafka-simple-consumer-shell.sh --broker-list trueack.ovh:9092 --offset -2 --max-messages 11 --partition 0 --topic test`
|
|
|
|
|
|
|
|
|