diff options
| author | Staffan Olsson <staffan@repos.se> | 2018-02-01 20:26:28 +0100 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2018-02-01 20:26:28 +0100 |
| commit | 09e422a36b425c9061effea26788ca7c0cfe929e (patch) | |
| tree | 02efcddfe6cc94e457c46e218986aa57c65b1ff9 | |
| parent | 7c1bc7ac341b98866187bd7b59a82f1c0140c661 (diff) | |
| download | kubernetes-kafka-09e422a36b425c9061effea26788ca7c0cfe929e.tar.gz kubernetes-kafka-09e422a36b425c9061effea26788ca7c0cfe929e.tar.bz2 kubernetes-kafka-09e422a36b425c9061effea26788ca7c0cfe929e.zip | |
Changes to consumergroup behavior, but TODO adapt the assert
| -rw-r--r-- | kafka/test/consumer-group.yml | 16 |
1 files 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: {} |