diff options
| -rw-r--r-- | kafka/test/produce-consume.yml | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/kafka/test/produce-consume.yml b/kafka/test/produce-consume.yml index f3a9961..d0632ab 100644 --- a/kafka/test/produce-consume.yml +++ b/kafka/test/produce-consume.yml @@ -74,6 +74,9 @@ spec: env: - name: BOOTSTRAP value: bootstrap.kafka:9092 + - name: ACKS + # -1 means use brokers' min.insync.replicas + value: "-1" command: - /bin/bash - -cex @@ -83,7 +86,7 @@ spec: ./bin/kafka-topics.sh --zookeeper zookeeper.kafka:2181 --describe --topic test-produce-consume ; tail -f /shared/produce.tmp | - ./bin/kafka-console-producer.sh --broker-list $BOOTSTRAP --topic test-produce-consume + ./bin/kafka-console-producer.sh --broker-list $BOOTSTRAP --topic test-produce-consume --producer-property "acks=$ACKS" ; volumeMounts: - name: config |