[root@master kafka]# kubectl create namespace kube-public
[root@master kafka]# helm install kafka bitnami/kafka -f kafka-values.yaml --namespace kube-public
NAME: kafka
LAST DEPLOYED: Mon Sep 9 21:07:48 2024
NAMESPACE: kube-public
STATUS: deployed
REVISION: 1
TEST SUITE: None
NOTES:
CHART NAME: kafka
CHART VERSION: 30.0.5
APP VERSION: 3.8.0
** Please be patient while the chart is being deployed **
Kafka can be accessed by consumers via port 9092 on the following DNS name from within your cluster:
kafka.kube-public.svc.cluster.local
Each Kafka broker can be accessed by producers via port 9092 on the following DNS name(s) from within your cluster:
kafka-controller-0.kafka-controller-headless.kube-public.svc.cluster.local:9092
kafka-controller-1.kafka-controller-headless.kube-public.svc.cluster.local:9092
kafka-controller-2.kafka-controller-headless.kube-public.svc.cluster.local:9092
To create a pod that you can use as a Kafka client run the following commands:
===>>> 临时客户端
kubectl run kafka-client --restart='Never' --image docker.io/bitnami/kafka:3.8.0-debian-12-r3 --namespace kube-public --command -- sleep infinity
kubectl exec --tty -i kafka-client --namespace kube-public -- bash
PRODUCER: ===>>> 生产者
kafka-console-producer.sh \
--broker-list kafka-controller-0.kafka-controller-headless.kube-public.svc.cluster.local:9092,kafka-controller-1.kafka-controller-headless.kube-public.svc.cluster.local:9092,kafka-controller-2.kafka-controller-headless.kube-public.svc.cluster.local:9092 \
--topic test
CONSUMER: ===>>> 消费者
kafka-console-consumer.sh \
--bootstrap-server kafka.kube-public.svc.cluster.local:9092 \
--topic test \
--from-beginning
**测试 Kafka**
### 升级
```bash
helm upgrade kafka -f kafka-values -n kafka
```
### **UI 界面**
```bash
[root@master kafka]# cat kafka-ui.yaml
apiVersion: apps/v1
kind: Deployment
metadata:
name: kafka-ui-deployment
labels:
app: kafka-ui
spec:
replicas: 1
selector:
matchLabels:
app: kafka-ui
template:
metadata:
labels:
app: kafka-ui
spec:
containers:
- name: kafka-ui
image: provectuslabs/kafka-ui:latest
env:
- name: KAFKA_CLUSTERS_0_NAME
value: "Kafka Cluster"
- name: KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS
value: ka-controller-0.kafka-controller-headless.kube-public.svc.cluster.local:9092,ka-controller-1.kafka-controller-headless.kube-public.svc.cluster.local:9092,ka-controller-2.kafka-controller-headless.kube-public.svc.cluster.local:9092
imagePullPolicy: IfNotPresent
resources:
requests:
memory: "256Mi"
cpu: "100m"
limits:
memory: "1024Mi"
cpu: "1000m"
ports:
- containerPort: 8080
---
apiVersion: v1
kind: Service
metadata:
name: kafka-ui-service
spec:
selector:
app: kafka-ui
type: NodePort
ports:
- protocol: TCP
port: 8080 # 有域名配置个ingress来访问，就不用nodeport了
targetPort: 8080
nodePort: 30180 # node port可以通过集群IP+端口访问
```
```bash
[root@master kafka]# kubectl apply -f kafka-ui.yaml -n kube-public
deployment.apps/kafka-ui-deployment created
```
---
# Agent Instructions: Querying This Documentation
If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.
Perform an HTTP GET request on the current page URL with the `ask` query parameter:
```
GET https://close.gitbook.io/yun-wei-bi-ji/kubernetes/helm/helm-an-zhuang-kafka.md?ask=
```
The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.
Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.