맥용 카프카 Consumer 로그 확인

여기서는 카프카 컨슈머에 접속해 로그를 확인하는 방법을 알아보도록 하겠습니다. 그와 더불어 직접 서버로 명령을 보내는 방법에 대해 알아보도록 하겠습니다.

맥용 카프카 설치

1. 카프카를 설치합니다. 현재 기준으로 4.0.0가 최신 버전입니다.

$ wget <https://archive.apache.org/dist/kafka/4.0.0/kafka_2.13-4.0.0.tgz>

• wget 명령어를 찾을 수 없으면 아래 명령으로 설치가 가능합니다.

$ brew install wget

1. 압축을 풉니다.

$ tar xvf kafka_2.13-4.0.0.tgz

카프카 Consumer 로그 확인

1. kafka bin 폴더로 이동합니다.

$ cd kafka_2.13-4.0.0/bin

1. 아래 명령을 실행해 카프카 컨슈머에 접속합니다.
   1. 형식 : kafka-console-consumer.sh –bootstrap-server [host:port] –topic [topic_name]
   2. 명령어 : kafka-console-consumer.sh
   3. 옵션 : –bootstrap-server 카프카 서버

$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9093 --topic platform_command

카프카 Producer 실행

1. kafka bin 폴더에서 아래 명령을 실행합니다.

$ ./kafka-console-producer.sh --bootstrap-server localhost:9092,localhost:9093 --topic platform_command
> test1
> test2
> test3
> test4

테스트 결과

• producer 콘솔에서 platform_command 토픽으로 명령을 실행하면 consumer 콘솔창에에서 갱신되는 것을 알 수 있습니다.

명령 실행 시 오류

• 버전 문제일 경우 자바 최신 버전을 설치합니다.

# java 최신 버전 설치
$ brew install openjdk@17

# 버전 확인
$ /usr/libexec/java_home -V

# 환경 설정
export JAVA_HOME=$(/usr/libexec/java_home -v 17)

echo 'export JAVA_HOME=$(/usr/libexec/java_home -v 17)' >> ~/.zshrc
source ~/.zshrc

consumer group list 확인 명령어

$ ./kafka-consumer-groups.sh --bootstrap-server localhost:9092,localhost:9093 --list

consumer group의 상세 정보 확인

$ ./kafka-consumer-groups.sh --bootstrap-server localhost:9092,localhost:9093 --group group1 --describe

카프카 프로듀서, 컨슈머 질문사항