From e5046b197ecd88041fa71ea45bdfdb488e630d7c Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Fri, 2 Feb 2018 10:26:51 +0100
Subject: Updates the basic kafkacat test to use a consumer group of size 1

---
 kafka/test/kafkacat.yml | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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:
-- 
cgit v1.2.3