You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/09/14 11:39:29 UTC

[incubator-streampipes-installer] 02/03: [hotfix] add wait for kafka init container

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

wiener pushed a commit to branch rel/0.67.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-installer.git

commit 2b3e0f0a45893a251920cb7d5971d5a75116dbc9
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Mon Sep 14 13:38:10 2020 +0200

    [hotfix] add wait for kafka init container
---
 .../pipeline-elements/sources-watertank-simulator-deployment.yaml      | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
index 716b269..bc3afb0 100644
--- a/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
+++ b/k8s/templates/extensions/pipeline-elements/sources-watertank-simulator-deployment.yaml
@@ -31,6 +31,9 @@ spec:
         - name: init-wait-consul
           image: alpine
           command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 consul 8600 && exit 0 || sleep 3; done; exit 1"]
+        - name: init-wait-kafka
+          image: alpine
+          command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 kafka 9092 && exit 0 || sleep 3; done; exit 1"]
       containers:
         - name: sinks-internal-jvm
           image: {{ .Values.streampipes.registry }}/sources-watertank-simulator:{{ .Values.streampipes.version }}