[beam] branch master updated: [BEAM-12604] Do not expose Zookeeper client port in Kafka k8s config

[heejong]

This is an automated email from the ASF dual-hosted git repository.

heejong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 3f9e1f3  [BEAM-12604] Do not expose Zookeeper client port in Kafka k8s 
config
     new f22868c  Merge pull request #15164 from ihji/BEAM-12604
3f9e1f3 is described below

commit 3f9e1f30b676f14e9415e68e30cb9a1f9fef8172
Author: Heejong Lee <heej...@gmail.com>
AuthorDate: Mon Jul 12 22:14:22 2021 -0700

    [BEAM-12604] Do not expose Zookeeper client port in Kafka k8s config
---
 .test-infra/kubernetes/kafka-cluster/03-zookeeper/30service.yml     | 1 -
 .test-infra/kubernetes/kafka-cluster/05-kafka/configmap-config.yaml | 6 +++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/.test-infra/kubernetes/kafka-cluster/03-zookeeper/30service.yml 
b/.test-infra/kubernetes/kafka-cluster/03-zookeeper/30service.yml
index 4fd6eca..2b0445e 100644
--- a/.test-infra/kubernetes/kafka-cluster/03-zookeeper/30service.yml
+++ b/.test-infra/kubernetes/kafka-cluster/03-zookeeper/30service.yml
@@ -23,4 +23,3 @@ spec:
     name: client
   selector:
     app: zookeeper
-  type: LoadBalancer
diff --git 
a/.test-infra/kubernetes/kafka-cluster/05-kafka/configmap-config.yaml 
b/.test-infra/kubernetes/kafka-cluster/05-kafka/configmap-config.yaml
index d9acf9f..bac8292 100644
--- a/.test-infra/kubernetes/kafka-cluster/05-kafka/configmap-config.yaml
+++ b/.test-infra/kubernetes/kafka-cluster/05-kafka/configmap-config.yaml
@@ -33,9 +33,9 @@ data:
       sleep 20
     done
     echo "Applying runtime configuration using confluentinc/cp-kafka:5.0.1"
-    kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --force 
--topic beam --partitions 1 --replication-factor 1
+    kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --force 
--topic beam --partitions 1 --replication-factor 3
     kafka-configs --zookeeper zookeeper:2181 --entity-type topics 
--entity-name beam --describe
-    kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --force 
--topic beam-runnerv2 --partitions 1 --replication-factor 1
+    kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --force 
--topic beam-runnerv2 --partitions 1 --replication-factor 3
     kafka-configs --zookeeper zookeeper:2181 --entity-type topics 
--entity-name beam-runnerv2 --describe
-    kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --force 
--topic beam-sdf --partitions 1 --replication-factor 1
+    kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --force 
--topic beam-sdf --partitions 1 --replication-factor 3
     kafka-configs --zookeeper zookeeper:2181 --entity-type topics 
--entity-name beam-sdf --describe