[Kafka] CMAK 브로커 클러스터 구축하기

 

3개의 카프카 서버(브로커 서버)를 띄었다면, 이것을 한개의 클러스터로 묶어준다.

보통 주키퍼도 3대 이상 띄우지만 테스트를 위해 최소한의 주키퍼만 사용하였다. 주키퍼 설명은 이전글을 참고

https://soobysu.tistory.com/96

[Kafka] Zookeeper 란?

---

config/zoo.cfg

#주키퍼 접속
docker exec -it zookeeper-1 /bin/bash
#주키퍼 뒤 숫자는 버전마다 상이할 수 있음
cd /opt/zookeeper-3.4.13/conf
vi zoo.cfg

tickTime=2000
initLimit=10
syncLimit=5
dataDir=/opt/zookeeper-3.4.13/data
clientPort=2181
autopurge.snapRetainCount=3
autopurge.purgeInterval=1

이미 앞에 도커컴포즈 파일에 설정을 env (환경변수) 설정을 해놨기 때문에 따로 만질건 없다.

- 만약 주키퍼가 여러대라면 주키퍼 끼리 서버를 묶어주어야 한다. (아래 설정 추가)

server.1=zookeeper1:2888:3888
server.2=zookeeper:2888:3888
server.3=zookeeper:2888:3888

• tickTime: 이는 Zookeeper에서 사용하는 기본 시간 단위로, 밀리초 단위
  이는 session timeout과 같은 여러 timeout에서 사용되며, 기본 값은 2000ms(2초)
• dataDir: 이는 Zookeeper의 트랜잭션 로그 및 스냅샷이 저장되는 디렉토리의 경로
• clientPort: 클라이언트가 Zookeeper 서버에 연결하는 데 사용하는 포트 기본 값은 2181
• initLimit: 이는 Zookeeper follower가 leader와 동기화를 수행하는 데 허용되는 시간(단위: tickTime)을 설정합니다.
• syncLimit: 이는 Zookeeper follower가 leader로부터 업데이트를 받는 데 허용되는 시간(단위: tickTime)을 설정합니다.
• server.X=Y:Z: 이 설정은 멀티노드 Zookeeper 설정을 위한 것으로, X는 서버 번호, Y는 해당 서버의 주소, Z는 리더 선출을 위한 포트를 나타냅니다.

---

CMAK 접속

http://localhost:9000 주소로 접속한다.

설정해준 아이디와 비밀번호로 로그인

사용자 이름 : admin

비밀번호 : password 

초기에는 다음과 같이 카프카 정보를 볼 수 없으므로, 관리 대상 카프카 정보로 클러스터를 생성하여 준다.

[Cluster -> Add Cluster 메뉴를 사용한다.]

---

만일 클러스터 목록을 추가하는 과정에서 아래와 같은 에러가 발생할 경우에는
zookeeper 콘솔을 통해 kafka-manager에서 사용할 공간을 직접 생성해 준 후, kafka-manager를 재기동한다.

Yikes! KeeperErrorCode = Unimplemented for /kafka-manager/mutex 

오류가 뜬다면 

https://soobysu.tistory.com/108

[Kafka] CMAK Unimplemented 에러

---

Add Cluster 

해당 클러스터 명 / zookeeper hosts / kafka version 작성 후 

완료.

Active 밑 클러스터 명을 누르면 클러스터로 접속

Modify 설정 변경 할 수 있다.

끗