diff options
| author | Staffan Olsson <staffan@repos.se> | 2016-10-18 11:34:27 +0200 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2016-10-25 12:19:42 +0200 |
| commit | 86dea9b84da598c5b99b77ba7b937b9216524ef3 (patch) | |
| tree | 99b1d9a6d0c7265f1db6c5c5b0de56034fe744ba | |
| parent | cfd2d3b614e645af18cd0a4b3e8e3ac8df8f8d4e (diff) | |
| download | kubernetes-kafka-86dea9b84da598c5b99b77ba7b937b9216524ef3.tar.gz kubernetes-kafka-86dea9b84da598c5b99b77ba7b937b9216524ef3.tar.bz2 kubernetes-kafka-86dea9b84da598c5b99b77ba7b937b9216524ef3.zip | |
Updates test commands for nopetset
| -rw-r--r-- | test/test.sh | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/test/test.sh b/test/test.sh index bfc4a8f..e47e20f 100644 --- a/test/test.sh +++ b/test/test.sh @@ -10,10 +10,13 @@ kubectl exec -ti testclient -- ./bin/kafka-console-consumer.sh --zookeeper zooke # Go ahead and produce messages echo "Write a message followed by enter, exit using Ctrl+C" -kubectl exec -ti testclient -- ./bin/kafka-console-producer.sh --broker-list kafka-0.broker.kafka.svc.cluster.local:9092 --topic test1 +kubectl exec -ti testclient -- ./bin/kafka-console-producer.sh --broker-list broker-0.kafka.svc.cluster.local:9092 --topic test1 -# Bootstrap even if two nodes are down (shorter name requires same namespace) -kubectl exec -ti testclient -- ./bin/kafka-console-producer.sh --broker-list kafka-0.broker:9092,kafka-1.broker:9092,kafka-2.broker:9092 --topic test1 +# Bootstrap even if two nodes are down +kubectl exec -ti testclient -- ./bin/kafka-console-producer.sh --broker-list broker-0.kafka.svc.cluster.local:9092,broker-1.kafka.svc.cluster.local:9092,broker-2.kafka.svc.cluster.local:9092 --topic test1 + +# Get a broker through the service +kubectl exec -ti testclient -- ./bin/kafka-console-producer.sh --broker-list kafka.kafka.svc.cluster.local:9092 --topic test1 # The following commands run in the pod kubectl exec -ti testclient -- /bin/bash @@ -22,13 +25,13 @@ kubectl exec -ti testclient -- /bin/bash ./bin/kafka-topics.sh --zookeeper zookeeper:2181 --describe --topic test2 ./bin/kafka-verifiable-consumer.sh \ - --broker-list=kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092 \ + --broker-list=kafka.kafka.svc.cluster.local:9092 \ --topic=test2 --group-id=A --verbose # If a topic isn't available this producer will tell you # WARN Error while fetching metadata with correlation id X : {topicname=LEADER_NOT_AVAILABLE} # ... but with current config Kafka will auto-create the topic ./bin/kafka-verifiable-producer.sh \ - --broker-list=kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092 \ + --broker-list=kafka.kafka.svc.cluster.local:9092 \ --value-prefix=1 --topic=test2 \ --acks=1 --throughput=1 --max-messages=10 |