diff options
author | Staffan Olsson <staffan@repos.se> | 2017-06-27 07:58:56 +0200 |
---|---|---|
committer | Staffan Olsson <staffan@repos.se> | 2017-06-27 07:58:56 +0200 |
commit | 49865bca8b3fd5fb214f4b9e88d490f9dd09104b (patch) | |
tree | c0dd704aa85310a058ee43b2dd3f7affba281ad6 | |
parent | f45ced550d55f58937f27b008ec73f6b51c6bd65 (diff) | |
download | kubernetes-kafka-49865bca8b3fd5fb214f4b9e88d490f9dd09104b.tar.gz kubernetes-kafka-49865bca8b3fd5fb214f4b9e88d490f9dd09104b.tar.bz2 kubernetes-kafka-49865bca8b3fd5fb214f4b9e88d490f9dd09104b.zip |
Adds a test that produces a message that you can see in the logs of 21consumer-test1
-rw-r--r-- | test/31producer-test1.yml | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/test/31producer-test1.yml b/test/31producer-test1.yml new file mode 100644 index 0000000..7a2e276 --- /dev/null +++ b/test/31producer-test1.yml @@ -0,0 +1,24 @@ +apiVersion: batch/v1 +kind: Job +metadata: + name: producer-test1 + namespace: kafka +spec: + template: + metadata: + name: producer-test1 + spec: + containers: + - name: kafka + image: solsson/kafka:0.11.0.0-rc2@sha256:c1316e0131f4ec83bc645ca2141e4fda94e0d28f4fb5f836e15e37a5e054bdf1 + command: + - /bin/sh + - -c + - > + echo "test1 $(date)" + | + ./bin/kafka-console-producer.sh + --topic test1 + --broker-list kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092 + ; sleep 1 + restartPolicy: Never |