카프카 매니저 설치 및 사용

설치 및 주키퍼 설정

 

우선 github.com/yahoo/CMAK/releases 에서 카프카 매니저를 다운로드 합니다.

 

zip이나 tar.gz를 받아주세요.

 

필자는 tar.gz를 받았습니다.

 

그리고 다운로드 받은 경로로 들어가 압축을 풀어줍시다.

tar -xf CMAK-3.0.0.5.tar.gz

압축을 푼 폴더의 sbt 파일을 이용해 빌드해줍니다.

./sbt clean dist

그러면 target/universal 디렉토리에 다시 cmak-3.0.0.5.zip 파일이 생깁니다.

이 파일은 배포용으로, 실행 가능한 파일들을 담고 있습니다.

 

원하는 위치에 cmak-3.0.0.5.zip 의 압축을 풀면 설치가 끝납니다.

unzip cmak-3.0.0.5.zip

---

설정 정보들은 conf/application.conf에 추가할 수 있습니다.

 

application.conf

...
cmak.zkhosts="localhost:2181, localhost:2182, localhost:2183"
cmak.zkhosts=${?ZK_HOSTS}
...

여러 설정 중 cmak.zkhosts 설정에 주키퍼 주소들을 넣어줍니다.

---

실행

 

아래의 명령어로 실행!

bin/cmak

로그가 뜨면서 카프카 매니저가 동작합니다.

기본 포트는 9000으로 잡혀있으므로 실행 후 브라우저를 통해 접속해봅시다.

 

 

 

접속하면 위와 같은 화면이 나타납니다. 간단하게 주키퍼 주소값들만 채워주고 클러스터를 추가합니다.

---

 

클러스터가 추가됐습니다. hello-kakfa 링크를 따라 들어가면 아래와 같은 화면이 나타납니다.

 

성공. 링크들을 따라 값들을 확인해보세요~

---

참고

카프카 매니저 실행시 설정된 주키퍼 주소와 연결되지 않을 때, 자동으로 종료되지 않고 계속 연결을 시도합니다.

이때 ctrl+c로 종료가 안될 때가 있습니다. 이럴때는 ctrl+z 로 프로세스를 멈추세요.

그리고 카프카 매니저가 실행될 때 홈 디렉토리에 RUNNING_PID 라는 파일이 생성되고 이 안에 PID 값이 들어있으니

kill -9 PID 

위의 명령어로 종료하세요. 그리고 다시 RUNNING_PID 파일은 지워줘야 재시작이 가능합니다.

(어느때나 ctrl+c로 종료했을 땐, 자동으로 제거됩니다.)