From 09e422a36b425c9061effea26788ca7c0cfe929e Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Thu, 1 Feb 2018 20:26:28 +0100
Subject: Changes to consumergroup behavior, but TODO adapt the assert

---
 kafka/test/consumer-group.yml | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/kafka/test/consumer-group.yml b/kafka/test/consumer-group.yml
index 98410bc..34b8ed7 100644
--- a/kafka/test/consumer-group.yml
+++ b/kafka/test/consumer-group.yml
@@ -1,7 +1,7 @@
 ---
 kind: ConfigMap
 metadata:
-  name: kafkacat
+  name: kafkacat-consumergroup
   namespace: test-kafka
 apiVersion: v1
 data:
@@ -47,7 +47,7 @@ data:
     fi
 
     # get info about this message
-    kafkacat -Q -b $BOOTSTRAP -t test-kafkacat:0:$LAST_TS \
+    kafkacat -Q -b $BOOTSTRAP -t test-kafkacat-consumergroup:0:$LAST_TS \
       -X socket.timeout.ms=600 -X session.timeout.ms=300 -X request.timeout.ms=50 -X metadata.request.timeout.ms=600
     [ $? -eq 0 ] || echo "At $(date +%FT%H:%M:%S.%3N) bootstrap broker(s) might be down"
     # but don't fail the test; producer and consumer should keep going if there are other brokers
@@ -65,7 +65,7 @@ data:
 apiVersion: batch/v1
 kind: Job
 metadata:
-  name: topic-test-kafkacat
+  name: topic-test-kafkacat-consumergroup
   namespace: test-kafka
 spec:
   template:
@@ -80,7 +80,7 @@ spec:
         - --create
         - --if-not-exists
         - --topic
-        -   test-kafkacat
+        -   test-kafkacat-consumergroup
         - --partitions
         -   "1"
       restartPolicy: Never
@@ -88,7 +88,7 @@ spec:
 apiVersion: apps/v1beta2
 kind: ReplicaSet
 metadata:
-  name: kafkacat
+  name: kafkacat-consumergroup
   namespace: test-kafka
 spec:
   replicas: 1
@@ -121,7 +121,7 @@ spec:
           echo "--- start $HOSTNAME $(date --iso-8601='ns' -u) ---" >> /shared/produce.tmp
           ;
           tail -f /shared/produce.tmp |
-          kafkacat -P -b $BOOTSTRAP -t test-kafkacat -v -T -d broker -K ':'
+          kafkacat -P -b $BOOTSTRAP -t test-kafkacat-consumergroup -v -T -d broker -K ':'
           ;
         volumeMounts:
         - name: config
@@ -137,7 +137,7 @@ spec:
         - /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 test-kafkacat-consumergroup test-kafkacat-consumergroup -f '%T;%k:%p;%o;%s\n' -u -d broker |
           tee /shared/consumed.tmp
           ;
         volumeMounts:
@@ -176,6 +176,6 @@ spec:
       volumes:
       - name: config
         configMap:
-          name: kafkacat
+          name: kafkacat-consumergroup
       - name: shared
         emptyDir: {}
-- 
cgit v1.2.3