aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2018-02-02 10:26:51 +0100
committerStaffan Olsson <staffan@repos.se>2018-02-02 10:26:51 +0100
commite5046b197ecd88041fa71ea45bdfdb488e630d7c (patch)
tree4b5ffefa29e92ac7e6c6900000eeb17092cb737b
parent7017fc07a1fef113e9494247ad94dbe07d64f4a3 (diff)
downloadkubernetes-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
-rw-r--r--kafka/test/kafkacat.yml5
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: