Zookeeper is being phased out so clients should use bootstrap servers

However --if-not-exists isn't supported without zookeeper so we have to use the hack from github.com/solsson/dockerfiles/tree/native/native/cli-scripts
Yolean · Jul 12, 2020 · 5f62075 · 5f62075
1 parent e201ea3
commit 5f62075
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/kafka/test/produce-consume.yml b/kafka/test/produce-consume.yml
@@ -57,11 +57,10 @@ spec:
       - name: topic-create
         image: solsson/kafka:native-cli@sha256:fbf29c59182fb87921c5199783d2d5796856ecbfe34a9c03eca658b3cf50f3c4
         command:
-        - ./bin/kafka-topics.sh
-        - --zookeeper
-        -   zookeeper.kafka.svc.cluster.local:2181
+        - kafka-topics_ifnotexists
+        - --bootstrap-server
+        -   bootstrap.kafka.svc.cluster.local:9092
         - --create
-        - --if-not-exists
         - --topic
         -   test-produce-consume
         resources: