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 | |
| 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.
| -rw-r--r-- | test/11topic-create-test1.yml (renamed from test/10topic-create-test1.yml) | 0 | ||||
| -rw-r--r-- | test/12topic-create-test2.yml | 25 | ||||
| -rw-r--r-- | test/99testclient.yml | 2 | ||||
| -rw-r--r-- | test/test.sh | 12 |
4 files changed, 38 insertions, 1 deletions
diff --git a/test/10topic-create-test1.yml b/test/11topic-create-test1.yml index fdb805e..fdb805e 100644 --- a/test/10topic-create-test1.yml +++ b/test/11topic-create-test1.yml diff --git a/test/12topic-create-test2.yml b/test/12topic-create-test2.yml new file mode 100644 index 0000000..45d9881 --- /dev/null +++ b/test/12topic-create-test2.yml @@ -0,0 +1,25 @@ +apiVersion: batch/v1 +kind: Job +metadata: + name: topic-create-test2 + namespace: kafka +spec: + template: + metadata: + name: topic-create-test2 + spec: + containers: + - name: kafka + image: solsson/kafka:0.10.0.1 + command: + - ./bin/kafka-topics.sh + - --zookeeper + - zookeeper:2181 + - --create + - --topic + - test2 + - --partitions + - "1" + - --replication-factor + - "3" + restartPolicy: Never diff --git a/test/99testclient.yml b/test/99testclient.yml index 97cbf3d..9be05d8 100644 --- a/test/99testclient.yml +++ b/test/99testclient.yml @@ -1,5 +1,5 @@ # Kafka image without the service, so you can run ./bin/ stuff -# kubectl exec -ti anythingclient -- /bin/bash +# kubectl exec -ti testclient -- /bin/bash apiVersion: v1 kind: Pod metadata: 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 |