diff options
| author | Staffan Olsson <staffan@repos.se> | 2018-01-09 08:34:34 +0100 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2018-01-09 08:35:21 +0100 |
| commit | e0596905822070c7472428e8482e9633cc851f9b (patch) | |
| tree | 4aec3663f32bdd5b1a30a0e29758acb3a629371a | |
| parent | e50b8eaaf1050bae3639367c91b280e189122301 (diff) | |
| download | kubernetes-kafka-test-producer-acks-config.tar.gz kubernetes-kafka-test-producer-acks-config.tar.bz2 kubernetes-kafka-test-producer-acks-config.zip | |
Makes producer acks configurable by envtest-producer-acks-config
The suggested -1 is equivalent to "all", see
https://kafka.apache.org/documentation/#producerconfigs
| -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 |