diff options
author | Staffan Olsson <staffan@repos.se> | 2016-09-05 08:57:20 +0200 |
---|---|---|
committer | Staffan Olsson <staffan@repos.se> | 2016-09-05 09:02:21 +0200 |
commit | 03454f1b6e9465d39d1b8cd30c540716364c5578 (patch) | |
tree | 86122f4e90f40d5520959528536cafb39a44a3ab /test | |
parent | 99f487d1e81404ba328c9330072e205bbc0cb176 (diff) | |
download | kubernetes-kafka-03454f1b6e9465d39d1b8cd30c540716364c5578.tar.gz kubernetes-kafka-03454f1b6e9465d39d1b8cd30c540716364c5578.tar.bz2 kubernetes-kafka-03454f1b6e9465d39d1b8cd30c540716364c5578.zip |
Describes setup and some manual testing
Diffstat (limited to 'test')
-rw-r--r-- | test/99testclient.yml | 14 | ||||
-rw-r--r-- | test/test.sh | 13 |
2 files changed, 27 insertions, 0 deletions
diff --git a/test/99testclient.yml b/test/99testclient.yml new file mode 100644 index 0000000..97cbf3d --- /dev/null +++ b/test/99testclient.yml @@ -0,0 +1,14 @@ +# Kafka image without the service, so you can run ./bin/ stuff +# kubectl exec -ti anythingclient -- /bin/bash +apiVersion: v1 +kind: Pod +metadata: + name: testclient +spec: + containers: + - name: kafka + image: solsson/kafka:0.10.0.1 + command: + - sh + - -c + - "exec tail -f /dev/null" diff --git a/test/test.sh b/test/test.sh new file mode 100644 index 0000000..f21fe87 --- /dev/null +++ b/test/test.sh @@ -0,0 +1,13 @@ + +# Create topic +kubectl exec testclient -- ./bin/kafka-topics.sh --zookeeper zookeeper:2181 --topic test1 --create --partitions 1 --replication-factor 1 + +# Set one of your terminals to listen to messages on the test topic +kubectl exec -ti testclient -- ./bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic test1 --from-beginning + +# Go ahead and produce topics, haven't found a way to do this directly through kubectl exec +kubectl exec -ti testclient -- /bin/bash +echo "Test $(date)" | ./bin/kafka-console-producer.sh --broker-list kafka-0.broker:9092 --topic test1 +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 |