update

Solutions/Kafka-Alert-Demo/cn-k3s-all-in-one.sh

@@ -0,0 +1,11 @@
+sudo mkdir -pv /opt/rancher/k3s
+curl -sfL https://rancher-mirror.rancher.cn/k3s/k3s-install.sh | INSTALL_K3S_MIRROR=cn INSTALL_K3S_SKIP_SELINUX_RPM=true sh -s - \
+--system-default-registry "registry.cn-hangzhou.aliyuncs.com" --data-dir=/opt/rancher/k3s --kube-apiserver-arg service-node-port-range=0-50000 --disable=traefik,servicelb
+#curl -sfL https://get.k3s.io | sh -s - --disable=traefik,servicelb                                   \
+#        --data-dir=/opt/rancher/k3s                                                                  \
+#        --kube-apiserver-arg service-node-port-range=0-50000
+
+sudo mkdir -pv ~/.kube/
+sudo cp /etc/rancher/k3s/k3s.yaml ~/.kube/config
+
+sudo snap install helm --classic

Solutions/Kafka-Alert-Demo/set-node-label.sh

@@ -0,0 +1,6 @@
+k8s_node=`sudo kubectl  get nodes | awk 'NR>1{print $1}'`
+
+sudo kubectl label node $k8s_node master_controller=enable
+sudo kubectl label node $k8s_node tsdb=enable
+sudo kubectl label node $k8s_node dfdb=enable
+sudo kubectl label node $k8s_node elasticsearch-warm=enable

Solutions/Kafka-Alert-Demo/setup-kafka-cluster-private.sh

@@ -0,0 +1,28 @@
+helm repo add bitnami https://charts.bitnami.com/bitnami
+helm repo update
+kubectl create namespace kafka || true
+helm upgrade --install kafka bitnami/kafka --namespace kafka \
+  --set global.security.allowInsecureImages=true             \
+  --set image.registry='images.onwalk.net'  \
+  --set image.repository='public/kafka'     \
+  --set image.tag='3.9.0-debian-12-r4'      \
+  --set replicaCount=3                      \
+  --set sasl.enabledMechanisms="PLAIN"      \
+  --set sasl.interBrokerMechanism=PLAIN     \
+  --set sasl.controllerMechanism=PLAIN      \
+  --set rbac.create=true                    \
+  --set externalAccess.enabled=true         \
+  --set externalAccess.autoDiscovery.enabled=true \
+  --set externalAccess.autoDiscovery.image.registry=images.onwalk.net \
+  --set externalAccess.autoDiscovery.image.repository=public/kubectl \
+  --set externalAccess.autoDiscovery.image.tag=1.32.0-debian-12-r0 \
+  --set controller.automountServiceAccountToken=true \
+  --set broker.automountServiceAccountToken=true \
+  --set sasl.client.users[0]=user1          \
+  --set sasl.client.passwords="test"        \
+  --set persistence.enabled=true            \
+  --set persistence.size=8Gi                \
+  --set externalZookeeper.enabled=false     \
+  --set zookeeper.enabled=false
+kubectl get pods --namespace kafka
+kubectl get svc --namespace kafka