diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-11-09 13:57:33 +0100 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-11-09 13:57:33 +0100 |
| commit | 8d3f485f3cc2304a04d7ffa66c9522d427e5dad1 (patch) | |
| tree | 72f13496307662e0432880810a6a1daca322f2c7 /test/basic-with-kafkacat.yml | |
| parent | dbf77898c4e6c1617fa7b8ec28347072ec86ec0f (diff) | |
| parent | d0c1440e3bdf59b802ff28ab25e2bacf24ebbb05 (diff) | |
| download | kubernetes-kafka-8d3f485f3cc2304a04d7ffa66c9522d427e5dad1.tar.gz kubernetes-kafka-8d3f485f3cc2304a04d7ffa66c9522d427e5dad1.tar.bz2 kubernetes-kafka-8d3f485f3cc2304a04d7ffa66c9522d427e5dad1.zip | |
Merge branch 'bootstrap-test-console-too' into bootstrap-test
Diffstat (limited to 'test/basic-with-kafkacat.yml')
| -rw-r--r-- | test/basic-with-kafkacat.yml | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/test/basic-with-kafkacat.yml b/test/basic-with-kafkacat.yml index e72cfbc..ae8a0ed 100644 --- a/test/basic-with-kafkacat.yml +++ b/test/basic-with-kafkacat.yml @@ -20,7 +20,7 @@ data: UNIQUE="${HOSTNAME}@$(date -u -Ins)" - echo "Test $UNIQUE" >> /shared/produce.tmp + echo "${UNIQUE: -41:5}:Test $UNIQUE" >> /shared/produce.tmp sleep $PC_WAIT LAST=$(tail -n 1 /shared/consumed.tmp) @@ -112,7 +112,7 @@ spec: spec: containers: - name: producer - image: solsson/kafkacat@sha256:ebebf47061300b14a4b4c2e1e4303ab29f65e4b95d34af1b14bb8f7ec6da7cef + image: solsson/kafkacat@sha256:b32eedf936f3cde44cd164ddc77dfcf7565a8af4e357ff6de1abe4389ca530c9 env: - name: BOOTSTRAP value: kafka-0.broker.kafka.svc.cluster.local:9092 @@ -123,7 +123,7 @@ spec: echo "--- start $HOSTNAME $(date --iso-8601='ns' -u) ---" >> /shared/produce.tmp ; tail -f /shared/produce.tmp | - kafkacat -P -b $BOOTSTRAP -t test-basic-with-kafkacat -v -T -d broker + kafkacat -P -b $BOOTSTRAP -t test-basic-with-kafkacat -v -T -d broker -K ':' ; volumeMounts: - name: config @@ -131,7 +131,7 @@ spec: - name: shared mountPath: /shared - name: consumer - image: solsson/kafkacat@sha256:ebebf47061300b14a4b4c2e1e4303ab29f65e4b95d34af1b14bb8f7ec6da7cef + image: solsson/kafkacat@sha256:b32eedf936f3cde44cd164ddc77dfcf7565a8af4e357ff6de1abe4389ca530c9 env: - name: BOOTSTRAP value: kafka-0.broker.kafka.svc.cluster.local:9092 @@ -139,7 +139,7 @@ spec: - /bin/bash - -cex - > - kafkacat -C -b $BOOTSTRAP -t test-basic-with-kafkacat -o -1 -f '%T;%p;%o;%s\n' -u -d broker | + kafkacat -C -b $BOOTSTRAP -t test-basic-with-kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker | tee /shared/consumed.tmp ; volumeMounts: @@ -148,7 +148,7 @@ spec: - name: shared mountPath: /shared - name: testcase - image: solsson/kafkacat@sha256:ebebf47061300b14a4b4c2e1e4303ab29f65e4b95d34af1b14bb8f7ec6da7cef + image: solsson/kafkacat@sha256:b32eedf936f3cde44cd164ddc77dfcf7565a8af4e357ff6de1abe4389ca530c9 env: - name: BOOTSTRAP value: kafka-0.broker.kafka.svc.cluster.local:9092 |