From 7470b6d24ef867d10ea0eb4aa52237533e64d033 Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Thu, 27 Jul 2017 09:55:53 +0200 Subject: Adds a service to use as "bootstrap" servers url ... i.e. to connect to any kafka broker and get a list of actual broker DNS names to talk to. --- 30bootstrap-service.yml | 11 +++++++++++ 1 file changed, 11 insertions(+) create mode 100644 30bootstrap-service.yml diff --git a/30bootstrap-service.yml b/30bootstrap-service.yml new file mode 100644 index 0000000..7c2a337 --- /dev/null +++ b/30bootstrap-service.yml @@ -0,0 +1,11 @@ +--- +apiVersion: v1 +kind: Service +metadata: + name: bootstrap + namespace: kafka +spec: + ports: + - port: 9092 + selector: + app: kafka -- cgit v1.2.3 From fabb292ba83821cfa7d5f5a0c8cf54a1bc33d454 Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Fri, 28 Jul 2017 21:38:53 +0200 Subject: Evaluates bootstrap; kafkacat ERRs on missing brokers ... so this solves the problem with maintaining the BOOTSTRAP string --- test/basic-with-kafkacat.yml | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/test/basic-with-kafkacat.yml b/test/basic-with-kafkacat.yml index a8974e8..46f145c 100644 --- a/test/basic-with-kafkacat.yml +++ b/test/basic-with-kafkacat.yml @@ -72,7 +72,8 @@ spec: env: - name: BOOTSTRAP #value: kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092 - value: kafka-0.broker.kafka.svc.cluster.local:9092 + #value: kafka-0.broker.kafka.svc.cluster.local:9092 + value: bootstrap.kafka.svc.cluster.local:9092 - name: ZOOKEEPER value: zookeeper.kafka.svc.cluster.local:2181 # Test set up -- cgit v1.2.3 From cfae0cc027695905e0e6de519533aeb4971b95cc Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Fri, 3 Nov 2017 14:06:58 +0100 Subject: Avoids change to the test case, as it causes conflict. We could have a separate bootstrap test instead. This reverts commit fabb292ba83821cfa7d5f5a0c8cf54a1bc33d454. --- test/basic-with-kafkacat.yml | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/test/basic-with-kafkacat.yml b/test/basic-with-kafkacat.yml index 46f145c..a8974e8 100644 --- a/test/basic-with-kafkacat.yml +++ b/test/basic-with-kafkacat.yml @@ -72,8 +72,7 @@ spec: env: - name: BOOTSTRAP #value: kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092 - #value: kafka-0.broker.kafka.svc.cluster.local:9092 - value: bootstrap.kafka.svc.cluster.local:9092 + value: kafka-0.broker.kafka.svc.cluster.local:9092 - name: ZOOKEEPER value: zookeeper.kafka.svc.cluster.local:2181 # Test set up -- cgit v1.2.3