k8s中怎么部署Kafka集群

1. 创建一个Kafka的StatefulSet：

```yaml

apiVersion: apps/v1

kind: StatefulSet

metadata:

name: kafka

spec:

serviceName: kafka

replicas: 3

selector:

matchLabels:

app: kafka

template:

metadata:

labels:

app: kafka

spec:

containers:

- name: kafka

image: wurstmeister/kafka

ports:

- containerPort: 9092

env:

- name: KAFKA_ADVERTISED_LISTENERS

value: PLAINTEXT://$(POD_IP):9092

- name: KAFKA_LISTENERS

value: PLAINTEXT://0.0.0.0:9092

```

2. 创建一个Kafka的Service：

```yaml

apiVersion: v1

kind: Service

metadata:

name: kafka

spec:

selector:

app: kafka

ports:

- protocol: TCP

port: 9092

targetPort: 9092

```

3. 应用以上配置文件：

```bash

kubectl apply -f kafka-statefulset.yaml

kubectl apply -f kafka-service.yaml

```

这样就可以在Kubernetes中部署一个简单的Kafka集群。当然，还可以根据实际需求进行更复杂的配置和调优。