diff options
| author | Staffan Olsson <staffan@repos.se> | 2016-09-05 15:08:31 +0200 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2016-09-05 15:08:43 +0200 |
| commit | dc682e584a13abd6256ec3ba6209dd28e929f0ae (patch) | |
| tree | 8a5b4b664f579cfbfa59f30270f1ee67ef2bf7cb /test/test.sh | |
| parent | 31d6c90bc924958eb7b9faaf4019cc3a48645413 (diff) | |
| download | kubernetes-kafka-dc682e584a13abd6256ec3ba6209dd28e929f0ae.tar.gz kubernetes-kafka-dc682e584a13abd6256ec3ba6209dd28e929f0ae.tar.bz2 kubernetes-kafka-dc682e584a13abd6256ec3ba6209dd28e929f0ae.zip | |
Something is unreliable. Verifiable consumer sometimes reports LEADER_NOT_AVAILABLE.
Diffstat (limited to 'test/test.sh')
| -rw-r--r-- | test/test.sh | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/test/test.sh b/test/test.sh index f21fe87..276350f 100644 --- a/test/test.sh +++ b/test/test.sh @@ -11,3 +11,15 @@ echo "Test $(date)" | ./bin/kafka-console-producer.sh --broker-list kafka-0.brok echo "Test $(date)" | ./bin/kafka-console-producer.sh --broker-list kafka-1.broker:9092,kafka-2.broker:9092 --topic test1 # "WARN Removing server from bootstrap.servers as DNS resolution failed: kafka-X.broker:9092" echo "Test $(date)" | ./bin/kafka-console-producer.sh --broker-list kafka-0.broker:9092,kafka-1.broker:9092,kafka-2.broker:9092,kafka-X.broker:9092 --topic test1 + +# Topic 2, replicated +./bin/kafka-topics.sh --zookeeper zookeeper:2181 --describe --topic topic2 + +./bin/kafka-verifiable-consumer.sh \ + --broker-list=kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092 \ + --topic=topic2 --group-id=A --verbose + +./bin/kafka-verifiable-producer.sh \ + --broker-list=kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092 \ + --value-prefix=1 --topic=test2 \ + --acks=1 --throughput=1 --max-messages=10 |