카프카 주키퍼 지노드 명령어 정리

지노드란?

서로 연결되어있는 서버들이 상태 정보 등을 주고받는데, 이때 key-value 형식으로 카프카 지노드에 저장된다. 지노드에 저장된 key-value 를 사용하여 분산 애플리케이션이 서로 데이터를 주고받고, 이러한 지노드에 접속하여 상태 정보를 확인할 수 있는 명령어에 대해 더 자세히 알아보자.

 

 

 

지노드 경로 설정

카프카의 환경설정 파일에서 지노드 경로를 설정할 수 있다.

vi /usr/local/kafka/config/server.properties

 

환경 설정 파일에서 아래 부분을 수정하자.

zooleeper.connect=servername/test-kafka

# test-kafka 경로로 설정

 

 

지노드 접속

/usr/local/zookeeper/bin/zkCli.sh

 

접속한 후, 아래 명령어를 통해서 지노드들을 확인할 수 있다.

ls /

 

 

 

지노드 명령어 정리

1) /test-kafka/controller

현재 카프카 클러스터의 컨트롤러 정보를 확인할 수 있다. 카프카에서는 클러스터 내 브로커 중 하나를 컨트롤러를 선정하여 브로커 레벨에서 실패를 감지하고 실패한 브로커에 의해 영향받는 모든 파티션의 리더 변경을 책임지고 있다. 컨트롤러인 브로커가 다운되면, 남아있는 브로커 중 하나가 컨트롤러가 된다.

 

2) /test-kafka/brokers

브로커 관련된 정보들이 저장된다. 카프카 설치시에 브로커 컨피그에서 수정한 broker.id 를 확인할 수 있다.  브로커는 시작시에 /brokers/ids 에 broker.id로 지노드를 작성하여 자신을 등록한다.

 

3) /test-kafka/topic/토픽이름

토픽의 파티션 수, ISR 구성 정보, 리더 정보 등 클러스터 내 토픽 정보들을 확인할 수 있다.

 

4) /test-kafka/consumers

컨슈머 관련된 정보들이 저장되며, 컨슈머가 각각의 파티션들에 대해 어디까지 읽었는지를 기록하는 오프셋 정보가 저장된다. 오프셋 정보는 지워지면 안되므로 주키퍼의 영구노드로 저장된다.

 

5) /test-kafka/config

토픽의 상세 설정 정보를 확인할 수 있다.