Uses min.insync.replicas for the kafkacat producer as well

solsson · solsson · commit 09aec3b8fec8 · 2018-11-28T10:13:52.000+01:00
diff --git a/kafka/test/kafkacat.yml b/kafka/test/kafkacat.yml
@@ -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-kafkacat -v -T -d broker -K ':'
+          kafkacat -P -b $BOOTSTRAP -t test-kafkacat -v -T -d broker -K ':' -X request.required.acks=-1
           ;
         volumeMounts:
         - name: config

Original file line number	Diff line number	Diff line change
`@@ -123,7 +123,7 @@ spec:`
`123`	`123`	`echo "--- start $HOSTNAME $(date --iso-8601='ns' -u) ---" >> /shared/produce.tmp`
`124`	`124`	`;`
`125`	`125`	`tail -f /shared/produce.tmp \|`
`126`		`- kafkacat -P -b $BOOTSTRAP -t test-kafkacat -v -T -d broker -K ':'`
	`126`	`+ kafkacat -P -b $BOOTSTRAP -t test-kafkacat -v -T -d broker -K ':' -X request.required.acks=-1`
`127`	`127`	`;`
`128`	`128`	`volumeMounts:`
`129`	`129`	`- name: config`