diff options
author | Staffan Olsson <staffan@repos.se> | 2018-02-02 10:26:51 +0100 |
---|---|---|
committer | Staffan Olsson <staffan@repos.se> | 2018-02-02 10:26:51 +0100 |
commit | e5046b197ecd88041fa71ea45bdfdb488e630d7c (patch) | |
tree | 4b5ffefa29e92ac7e6c6900000eeb17092cb737b /kafka/test/kafkacat.yml | |
parent | 7017fc07a1fef113e9494247ad94dbe07d64f4a3 (diff) | |
download | kubernetes-kafka-e5046b197ecd88041fa71ea45bdfdb488e630d7c.tar.gz kubernetes-kafka-e5046b197ecd88041fa71ea45bdfdb488e630d7c.tar.bz2 kubernetes-kafka-e5046b197ecd88041fa71ea45bdfdb488e630d7c.zip |
Updates the basic kafkacat test to use a consumer group of size 1
Diffstat (limited to 'kafka/test/kafkacat.yml')
-rw-r--r-- | kafka/test/kafkacat.yml | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/kafka/test/kafkacat.yml b/kafka/test/kafkacat.yml index 98410bc..fe1c396 100644 --- a/kafka/test/kafkacat.yml +++ b/kafka/test/kafkacat.yml @@ -91,6 +91,7 @@ metadata: name: kafkacat namespace: test-kafka spec: + # Note that this test sets a consumer group, but asserts assume that the tests gets its own messages replicas: 1 selector: matchLabels: @@ -133,11 +134,13 @@ spec: env: - name: BOOTSTRAP value: bootstrap.kafka:9092 + - name: CONSUMER_GROUP_ID + value: test-kafkacat-group command: - /bin/bash - -cex - > - kafkacat -C -b $BOOTSTRAP -t test-kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker | + kafkacat -b $BOOTSTRAP -G $CONSUMER_GROUP_ID test-kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker | tee /shared/consumed.tmp ; volumeMounts: |