diff options
| -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 |