Kafka를 간편히 배포하기 위한 Helm Chart
Kubernetes용 대시보드, Kafka, Kafka-ui, Kafka-connect를 포함한다.
다른 컴포넌트(Grafana, Streams, ...) 추가 시 별도 릴리즈로 배포하자.
# broker 3, connect 1, private ip, KRAFT
helm install test https://github.com/YunanJeong/simple-kafka-deploy/releases/download/v2.0.4/skafka-2.0.4.tgz \
-f https://github.com/YunanJeong/simple-kafka-deploy/releases/download/v2.0.4/kraft-multi.yaml# broker 3, connect 1, public ip, KRAFT
helm install test https://github.com/YunanJeong/simple-kafka-deploy/releases/download/v2.0.4/skafka-2.0.4.tgz \
-f https://github.com/YunanJeong/simple-kafka-deploy/releases/download/v2.0.4/kraft-multi.yaml \
--set "kafka.externalAccess.autoDiscovery.enabled=false" \
--set "kafka.externalAccess.controller.service.nodePorts={30003,30004,30005}"# helm install {releaseName} {chart} -f {customValue.yaml}
# broker 3, connect 1, private ip, KRAFT
helm install test skafka-2.0.4.tgz -f values/kraft-multi.yaml
# broker 1, connect 1, private ip, KRAFT
helm install test skafka-2.0.4.tgz -f values/kraft-multi.yaml --set "kafka.controller.replicaCount=1"
# broker 3, connect 1, public ip, KRAFT
helm install test skafka-2.0.4.tgz -f values/kraft-multi.yaml \
--set "kafka.externalAccess.autoDiscovery.enabled=false" \
--set "kafka.externalAccess.controller.service.nodePorts={30003,30004,30005}"
# broker 1, connect 1, public ip, KRAFT
helm install test skafka-2.0.4.tgz -f values/kraft-multi.yaml \
--set "kafka.externalAccess.autoDiscovery.enabled=false" \
--set "kafka.externalAccess.controller.service.nodePorts={30003}"
--set "kafka.controller.replicaCount=1"- LB Port: 9095
- NP Port: 30003,30004,30005
외부에서 접근시 LB Port를 이용하되, 모든 NP Port에 대한 네트워크 인가 필요- NP Port로 개별 broker에 직접접근해도 되지만, 부하분산 효과가 없고, 포트가 직접 노출되어 보안상 좋지 않음
##################################################################################################
# K8s기반 Kafka에서 외부 Client와 Broker 간 통신과정
# 1. Client가 LoadBalancer의 주소(tcp-external)로 접근
# 2. LoadBalancer는 Client의 최초 접근 트래픽을 Broker 1개에 랜덤매칭하여 포워딩 (K8s의 LoadBalancer 기능)
# 3. 해당 Broker는 자신에게 직접 접근가능한 주소를 Kafka Client에게 전달 (Kafka의 advertised.listener 기능)
# 4. Kafka Client는 connection이 유지되는 동안 Broker로부터 받은 주소로 통신
##################################################################################################- Kafka-UI: http://ui4kafka.test.wai
- K8s-Dashboard: http://k8dashboard.test.wai
- 접속할 클라이언트 PC의 hosts 파일에 다음과 같이 내용 추가 필요
# 리눅스 /etc/hosts
# 윈도우 C:\Windows\System32\drivers\etc\hosts
# {serverIP} {appName}.{releaseName}.wai
X.X.X.X ui4kafka.test.wai
X.X.X.X k8dashboard.test.wai# 실행중인 릴리즈 조회 및 삭제
helm list
helm uninstall test
# 과거 내역이 있는 경우(persistence) 삭제
kubectl get pvc
kubectl delete pvc {pvcName}.
├── reference/ # (단순 참고용) 하위 차트의 default value
├── skafka/ # 헬름차트 디렉토리
│ ├── Chart.lock # 하위차트 버전 확정
│ ├── charts/ # 하위차트 생성 경로
│ ├── Chart.yaml # 버전관리 (차트, 앱, 하위차트)
│ ├── templates/ # Helm template
│ └── values.yaml # default value
├── values/ # 배포시 오버라이딩할 custom value 모음
│ ├── kraft-multi.yaml # 샘플(local ip)
│ └── kraft-multi-ec2.yaml # 샘플(public ip)
└── skafka-x.x.x.tgz # 차트 배포용 아카이브 파일# 차트의 default value 참고하여 custom value 파일 작성
helm show values skafka-2.0.4.tgz
# 업데이트
helm upgrade test skafka-2.0.4.tgz -f values/my-kraft-multi.yaml# dependency 다운로드 및 Chart.lock 최신화
helm dependency update skafka/
# 차트를 아카이브 파일로 생성
helm package skafka/- 보안설정이 없으면 파워쉘 사용불가 [참고]
- 윈도에선 일반 cmd를 사용
- curl, kafkacat, kafka-topics.sh 등으로 확인
- Kafka 최종 정상동작 테스트시 반드시 Produce, Consume 기능을 확인한다.
- Kafka의 EXTERNAL AdvertisedListener가 자동등록될 때, helm value에 따라 local ip가 될 수도, public ip가 될 수도 있다. 경우에 따라 produce,consume이 불가능할 수 있으므로 체크 필수
kafka-test에 문서화
- offset관련 토픽의 replication.factors 수가 브로커 수보다 많으면 문제 발생
- 시스템 부하가 심할 때 브로커 간 일부 연동 실패로, 같은 현상이 발생할 수 있다. 이후 부하가 완화되어도 해당 증상이 지속된다. 될 때까지 브로커를 재실행하거나, 스케일아웃, 최적화 등으로 해결하자.