diff options
-rw-r--r-- | test/kafkacat.yml (renamed from test/basic-with-kafkacat.yml) | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/test/basic-with-kafkacat.yml b/test/kafkacat.yml index ae8a0ed..b14f7f0 100644 --- a/test/basic-with-kafkacat.yml +++ b/test/kafkacat.yml @@ -1,7 +1,7 @@ --- kind: ConfigMap metadata: - name: test-basic-with-kafkacat + name: test-kafkacat namespace: test-kafka apiVersion: v1 data: @@ -45,7 +45,7 @@ data: fi # get info about this message - kafkacat -Q -b $BOOTSTRAP -t test-basic-with-kafkacat:0:$LAST_TS \ + kafkacat -Q -b $BOOTSTRAP -t test-kafkacat: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 @@ -63,7 +63,7 @@ data: apiVersion: batch/v1 kind: Job metadata: - name: test-basic-with-kafkacat + name: test-kafkacat namespace: test-kafka spec: template: @@ -78,7 +78,7 @@ spec: - --create - --if-not-exists - --topic - - test-basic-with-kafkacat + - test-kafkacat - --partitions - "1" - --replication-factor @@ -88,7 +88,7 @@ spec: apiVersion: apps/v1beta2 kind: Deployment metadata: - name: test-basic-with-kafkacat + name: test-kafkacat namespace: test-kafka spec: replicas: 1 @@ -123,7 +123,7 @@ spec: echo "--- start $HOSTNAME $(date --iso-8601='ns' -u) ---" >> /shared/produce.tmp ; tail -f /shared/produce.tmp | - kafkacat -P -b $BOOTSTRAP -t test-basic-with-kafkacat -v -T -d broker -K ':' + kafkacat -P -b $BOOTSTRAP -t test-kafkacat -v -T -d broker -K ':' ; volumeMounts: - name: config @@ -139,7 +139,7 @@ spec: - /bin/bash - -cex - > - kafkacat -C -b $BOOTSTRAP -t test-basic-with-kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker | + kafkacat -C -b $BOOTSTRAP -t test-kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker | tee /shared/consumed.tmp ; volumeMounts: @@ -178,6 +178,6 @@ spec: volumes: - name: config configMap: - name: test-basic-with-kafkacat + name: test-kafkacat - name: shared emptyDir: {} |