strimzi on docker desktop k8s

 

환경

• Mac M1
• docker desktop

 

기본적으로 https://strimzi.io/quickstarts/ 를 따르면 된다.

kubectl create namespace kafka

kubectl create -f 'https://strimzi.io/install/latest?namespace=kafka' -n kafka

kubectl apply -f https://strimzi.io/examples/latest/kafka/kafka-persistent-single.yaml -n kafka

 

pv pending 걸리면 

apiVersion: v1
kind: PersistentVolume
metadata:
  finalizers:
  - kubernetes.io/pv-protection
  name: pvc-data-my-cluster-zookeeper-0
spec:
  accessModes:
  - ReadWriteOnce
  capacity:
    storage: 100Gi
  claimRef:
    apiVersion: v1
    kind: PersistentVolumeClaim
    name: data-my-cluster-zookeeper-0
    namespace: kafka
  hostPath:
    path: /Users/mooney/Downloads/strimzi/k8s-pvs/data-my-cluster-zookeeper-0/pvc-data-my-cluster-zookeeper-0
    type: ""
  persistentVolumeReclaimPolicy: Delete
  storageClassName: hostpath
  volumeMode: Filesystem
  
---
apiVersion: v1
kind: PersistentVolume
metadata:
  finalizers:
  - kubernetes.io/pv-protection
  name: pvc-data-0-my-cluster-kafka-0
spec:
  accessModes:
  - ReadWriteOnce
  capacity:
    storage: 100Gi
  claimRef:
    apiVersion: v1
    kind: PersistentVolumeClaim
    name: data-0-my-cluster-kafka-0
    namespace: kafka
  hostPath:
    path: /Users/mooney/Downloads/strimzi/k8s-pvs/data-0-my-cluster-kafka-0/pvc-data-0-my-cluster-kafka-0
    type: ""
  persistentVolumeReclaimPolicy: Delete
  storageClassName: hostpath
  volumeMode: Filesystem

 

kubectl wait kafka/my-cluster --for=condition=Ready --timeout=300s -n kafka

condition met이 뜨면

 

producer 를 띄워서 hello world 테스트해보자, 

https://strimzi.io/quickstarts/에는 bootstrap 서비스 주소가 잘못되어있어서 producer 에러가 나는데 

 

WARN Couldn't resolve server my-cluster-kafka-bootstrap:9092 from bootstrap.servers as DNS resolution failed for my-cluster-kafka-bootstrap (org.apache.kafka.clients.ClientUtils)

 

namespace 주소 고려해서 producer 와 consumer의 bootstrap 서비스 주소만 바꿔준다.

kubectl -n kafka run kafka-producer -ti --image=quay.io/strimzi/kafka:0.39.0-kafka-3.6.1 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server my-cluster-kafka-bootstrap.kafka.svc.cluster.local:9092 --topic my-topic

If you don't see a command prompt, try pressing enter.
>Hello strimzi


kubectl -n kafka run kafka-consumer -ti --image=quay.io/strimzi/kafka:0.39.0-kafka-3.6.1 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server my-cluster-kafka-bootstrap.kafka.svc.cluster.local:9092 --topic my-topic --from-beginning

If you don't see a command prompt, try pressing enter.
Hello strimzi