Commit b7e6b698 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Deployment: 

- Corrected deployment of kafka so that it can be deployed multiple times in different namespaces
parent d531f6ae

deploy/kafka.sh

+5 −4
Original line number Diff line number Diff line
@@ -57,11 +57,12 @@ function kafka_deploy() { 
    # Kafka zookeeper service should be deployed before the kafka service

    kubectl --namespace ${KFK_NAMESPACE} apply -f "${TMP_MANIFESTS_FOLDER}/${KFK_ZOOKEEPER_MANIFEST}"



    KFK_ZOOKEEPER_SERVICE="zookeeper-service"    # this command may be replaced with command to extract service name automatically

    KFK_ZOOKEEPER_IP=$(kubectl --namespace ${KFK_NAMESPACE} get service ${KFK_ZOOKEEPER_SERVICE} -o 'jsonpath={.spec.clusterIP}')

    #KFK_ZOOKEEPER_SERVICE="zookeeper-service"    # this command may be replaced with command to extract service name automatically

    #KFK_ZOOKEEPER_IP=$(kubectl --namespace ${KFK_NAMESPACE} get service ${KFK_ZOOKEEPER_SERVICE} -o 'jsonpath={.spec.clusterIP}')



    # Kafka service should be deployed after the zookeeper service

    sed -i "s/<ZOOKEEPER_INTERNAL_IP>/${KFK_ZOOKEEPER_IP}/" "${TMP_MANIFESTS_FOLDER}/$KFK_MANIFEST"

    #sed -i "s/<ZOOKEEPER_INTERNAL_IP>/${KFK_ZOOKEEPER_IP}/" "${TMP_MANIFESTS_FOLDER}/$KFK_MANIFEST"

    sed -i "s/<KAFKA_NAMESPACE>/${KFK_NAMESPACE}/" "${TMP_MANIFESTS_FOLDER}/$KFK_MANIFEST"



    # echo ">>> Deploying Apache Kafka Broker"

    kubectl --namespace ${KFK_NAMESPACE} apply -f "${TMP_MANIFESTS_FOLDER}/$KFK_MANIFEST"

manifests/kafka/01-zookeeper.yaml

+4 −6
Original line number Diff line number Diff line
@@ -19,14 +19,13 @@ metadata: 
  labels:

    app: zookeeper-service

  name: zookeeper-service

  namespace: kafka

spec:

  type: NodePort

  type: ClusterIP

  ports:

    - name: zookeeper-port

      port: 2181

      nodePort: 30181

      targetPort: 2181

      #nodePort: 30181

      #targetPort: 2181

  selector:

    app: zookeeper

---
@@ -36,7 +35,6 @@ metadata: 
  labels:

    app: zookeeper

  name: zookeeper

  namespace: kafka

spec:

  replicas: 1

  selector:

manifests/kafka/02-kafka.yaml

+3 −4
Original line number Diff line number Diff line
@@ -19,7 +19,6 @@ metadata: 
  labels:

    app: kafka-broker

  name: kafka-service

  namespace: kafka

spec:

  ports:

  - port: 9092
@@ -32,7 +31,6 @@ metadata: 
  labels:

    app: kafka-broker

  name: kafka-broker

  namespace: kafka

spec:

  replicas: 1

  selector:
@@ -49,11 +47,12 @@ spec: 
        - name: KAFKA_BROKER_ID

          value: "1"

        - name: KAFKA_ZOOKEEPER_CONNECT

          value: <ZOOKEEPER_INTERNAL_IP>:2181

          #value: <ZOOKEEPER_INTERNAL_IP>:2181

          value: zookeeper-service.<KAFKA_NAMESPACE>.svc.cluster.local:2181

        - name: KAFKA_LISTENERS

          value: PLAINTEXT://:9092

        - name: KAFKA_ADVERTISED_LISTENERS

          value: PLAINTEXT://kafka-service.kafka.svc.cluster.local:9092

          value: PLAINTEXT://kafka-service.<KAFKA_NAMESPACE>.svc.cluster.local:9092

        image: wurstmeister/kafka

        imagePullPolicy: IfNotPresent

        name: kafka-broker