feat: kafka with kraft

Author: Angular2Guy

backend/runKafka.sh

@@ -0,0 +1,18 @@
+#!/bin/sh
+# network config for KRaft
+docker network create app-tier --driver bridge
+# Kafka with KRaft
+docker run -d \
+    -p 9092:9092 \
+    --name kafka-server \
+    --hostname kafka-server \
+    --network app-tier \
+    -e KAFKA_CFG_NODE_ID=0 \
+    -e KAFKA_CFG_PROCESS_ROLES=controller,broker \
+    -e KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093 \
+    -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT \
+    -e KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=0@kafka-server:9093 \
+    -e KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER \
+    bitnami/kafka:latest
+# Start Kafka with KRaft
+docker start kafka-server

minikube/angularandspringwithkafka/templates/_helpers.tpl

@@ -49,24 +49,6 @@ Create envApp values
 {{- end}}
 {{- end }}
 
-{{/*
-Create envZookeeper values
-*/}}
-{{- define "helpers.list-envZookeeperApp-variables"}}
-{{- $secretName := .Values.secret.nameZookeeper -}}
-{{- range $key, $val := .Values.envZookeeper.secret }}
-- name: {{ $key }}
-  valueFrom:
-    secretKeyRef:
-      name: {{ $secretName }}
-      key: {{ $key }}
-{{- end}}
-{{- range $key, $val := .Values.envZookeeper.normal }}
-- name: {{ $key }}
-  value: {{ $val | quote }}
-{{- end}}
-{{- end }}
-
 {{/*
 Create envKafka values
 */}}

minikube/angularandspringwithkafka/templates/kubTemplate.yaml

@@ -60,50 +60,6 @@ spec:
 ---
 apiVersion: apps/v1
 kind: Deployment
-metadata:
-  name: {{ .Values.zookeeperName }}
-  labels:
-    app: {{ .Values.zookeeperName }}
-spec:
-  replicas: 1
-  selector:
-    matchLabels:
-      app: {{ .Values.zookeeperName }}
-  template:
-    metadata:
-      labels:
-        app: {{ .Values.zookeeperName }}
-    spec:
-      containers:
-      - name: {{ .Values.zookeeperName }}
-        image: "{{ .Values.zookeeperImageName }}:{{ .Values.zookeeperImageVersion }}"
-        resources:
-          limits:
-            memory: "768M"
-            cpu: "0.5"
-          requests:
-            memory: "512M"
-            cpu: "0.5"
-        env:
-          {{- include "helpers.list-envZookeeperApp-variables" . | indent 10 }}
-        ports:
-        - containerPort: 2181
----
-apiVersion: v1
-kind: Service
-metadata:
-  name: {{ .Values.zookeeperServiceName }}
-  labels:
-    app: {{ .Values.zookeeperServiceName }}
-spec:
-  ports:
-  - port: 2181
-    protocol: TCP
-  selector:
-    app: {{ .Values.zookeeperName }}
----
-apiVersion: apps/v1
-kind: Deployment
 metadata:
   name: {{ .Values.kafkaName }}
   labels:
@@ -154,9 +110,13 @@ metadata:
 spec:
 #  type: NodePort
   ports:
-  - port: 9092
-#    nodePort: 9092
+  - name: tcp-client
+    port: 9092
+    protocol: TCP
+  - name: tcp-interbroker
+    port: 9093
     protocol: TCP
+    targetPort: 9093
   selector:
     app: {{ .Values.kafkaName }}
 ---

minikube/angularandspringwithkafka/values.yaml

@@ -31,21 +31,12 @@ envApp:
     KAFKA_SERVICE_NAME: kafkaService
   secret:
     JWTTOKEN_SECRET: secret-key1234567890abcdefghijklmnopqrstuvwxyz
-    
-envZookeeper:
-  normal: 
-    ALLOW_ANONYMOUS_LOGIN: yes
-  secret:
-   ZOOKEEPER_TICK_TIME: "2000"
 
 envKafka:
   normal: 
-    KAFKA_BROKER_ID: "1"
-    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
-    KAFKA_CFG_LISTENERS: PLAINTEXT://:9092
-    KAFKA_CFG_ADVERTISED_LISTENERS: PLAINTEXT://:9092
-    KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: false
-    ALLOW_PLAINTEXT_LISTENER: yes
-    KAFKA_ENABLE_KRAFT: false
-  secret:
-    KAFKA_ZOOKEEPER_CONNECT: "zookeeperservice:2181"  
+    KAFKA_CFG_NODE_ID: 0
+    KAFKA_CFG_PROCESS_ROLES: controller,broker
+    KAFKA_CFG_LISTENERS: PLAINTEXT://:9092,CONTROLLER://:9093
+    KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
+    KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: 0@kafkaservice:9093
+    KAFKA_CFG_CONTROLLER_LISTENER_NAMES: CONTROLLER