helm을이용해 k8s에 kafka 설치하기!

1. helm의 repository에 bitnami를 추가한다.

helm repo add bitnami https://charts.bitnami.com/bitnami

helm search를 통해 추가된 것을 확인

helm search

kafka가 보인다.

 

2. kafka를 담을 namespace 생성

 

kubectl create ns kafka

helm install --name bonah bitnami/kafka --namespace kafka

kafka와 zookeeper 서버 설치 완료!

 

간단한 producer, consumer 사용해보기

 

# producer

kubectl run bonah-kafka-client --restart='Never' --image docker.io/bitnami/kafka:2.6.0-debian-10-r0 --namespace kafka --command -- sleep infinity

kubectl exec --tty -i bonah-kafka-client --namespace kafka -- bash

 

kafka-console-producer.sh \
--broker-list bonah-kafka-0.bonah-kafka-headless.kafka.svc.cluster.local:9092 \
--topic test

 

kafka-console-consumer.sh \
--bootstrap-server bonah-kafka.kafka.svc.cluster.local:9092 \
--topic test \
--from-beginning