Kafka

Kafka是一个开源的分布式流处理平台，主要用于处理实时数据流。它可以高效地发布和订阅消息，存储数据流，并处理这些数据。Kafka通常用于构建数据管道和流应用，能够保证高吞吐量、低延迟和高可扩展性。

• 官网链接

查看版本

helm search repo bitnami/kafka -l

下载chart

helm pull bitnami/kafka --version 30.1.8

修改配置

根据环境做出相应的修改

cat values.yaml

创建标签，运行在标签节点上

kubectl label nodes server02.lingo.local kubernetes.service/kafka="true"
kubectl label nodes server03.lingo.local kubernetes.service/kafka="true"

创建服务

helm install kafka -n kongyu -f values.yaml kafka-30.1.8.tgz

查看服务

kubectl get -n kongyu pod,svc,pvc -l app.kubernetes.io/instance=kafka
kubectl logs -f -n kongyu kafka-controller-0

使用服务

创建客户端容器

kubectl run kafka-client -i --tty --rm --restart='Never' --image registry.lingo.local/bitnami/kafka:3.8.1 --namespace kongyu --command -- bash

内部网络访问-headless

## 生产数据
kafka-console-producer.sh \
    --broker-list kafka-broker-0.kafka-broker-headless.kongyu:9092,kafka-broker-1.kafka-broker-headless.kongyu:9092,kafka-broker-2.kafka-broker-headless.kongyu:9092 \
    --topic test
## 消费数据
kafka-console-consumer.sh \
    --bootstrap-server kafka-broker-0.kafka-broker-headless.kongyu:9092,kafka-broker-1.kafka-broker-headless.kongyu:9092,kafka-broker-2.kafka-broker-headless.kongyu:9092 \
    --topic test \
    --from-beginning

内部网络访问

## 生产数据
kafka-console-producer.sh \
    --broker-list kafka.kongyu:9092 \
    --topic test
## 消费数据
kafka-console-consumer.sh \
    --bootstrap-server kafka.kongyu:9092 \
    --topic test \
    --from-beginning

集群网络访问

使用集群+NodePort访问，使用kafka-controller-0-external服务的端口

## 生产数据
kafka-console-producer.sh \
    --broker-list 192.168.1.10:40180,192.168.1.10:31859,192.168.1.10:42739 \
    --topic test
## 消费数据
kafka-console-consumer.sh \
    --bootstrap-server 192.168.1.10:40180,192.168.1.10:31859,192.168.1.10:42739 \
    --topic test \
    --from-beginning

删除服务以及数据

helm uninstall -n kongyu kafka
kubectl delete pvc -n kongyu -l app.kubernetes.io/instance=kafka