Apache Kafka: local을 위한 명령어 인터페이스 (CLI)

Kafka

심심해서 만들어본 툴

Apache Kafka

참고: Hyper-V 가상환경에서 Kafka 서버 만들기

---

 

1. 소개

아직, 실행 파일로 만들거나 소스를 최적화하진 않았지만 실행 가능 상태이다.

Confluent로 local 개발을 해보려고 했으나 confluent local은 매번 실행할 때마다

Kafka 데이터가 날아간다. 터미널에서 명령어로 카프카를 주로 돌리는데,

서버가 잘 실행이 된건지, 출력이 애매하고, 명령어가 길어 힘들어서 하나 만들었다.

 

TO-DO: 최적화

 

기능

• 주키퍼 서버, 카프카 서버 실행
• 주키퍼 서버, 카프카 서버 종료
• 주키퍼 서버, 카프카 서버 로그 보기
• 카프카 토픽 생성/제거/목록/설정
• 토픽 데이터 | Producer/Consumer

 

2. 사용법

LINUX / UBUNTU

cli.py

0.02MB

pid.ini

0.00MB

아직은 정상 작동하려면 kafka 설치 폴더에 가서 (bin폴더 이전) 위 cli.py와 pid.ini를 다운로드해야 한다.

(또는 Github에서 최신 버전)

 

아무런 설정을 하지 않으면, 주키퍼 서버 = localhost:2181, 카프카 서버 = localhost:9092

 

CLI는 PyInquirer로 간단히 만들었다. (키보드 위아래로 조작)

 

메인 메뉴

주키퍼 서버 포트 1234, 카프카 서버 포트 4494에서 열기

(옵션 없이하면 기본값)

properties 설정에 맞는 서버를 입력한다. 또는 설정없이 기본값으로 실행

 

우선, 주키퍼와 카프카 서버 실행 메뉴이다.

gui.py 실행

주키퍼 실행

 

아래는 주키퍼 서버가 정상 실행된 모습

 

토픽 생성 메뉴

서버 정상 작동 중

 

토픽 목록

topic list

서버 종료 및 CLI 종료

 

Alfex4936/Kafka-Local-CLI