1. kafka client 다운로드
https://kafka.apache.org/downloads
Binary 다운로드
tgz파일 압축 풀어서 C에 갖다놓기
(실행시 path가 길면 "입력 줄이 너무 깁니다." 가 뜨기 때문)
2. 클러스터에 연결하기 위해 IAM 인증을 사용할 것이므로 IAM 인증용 jar 다운로드
https://github.com/aws/aws-msk-iam-auth/releases
jar 파일을 libs 폴더 밑에 넣는다.(C에 위치한 경우 C:\kafka_2.13-3.6.1\libs 의 밑 )
3. config 폴더 밑에 client.properties 파일 생성하여 아래 내용 입력
security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
cmd에서 bin\windows로 가서 명령어 입력하면 됨
토픽 리스트 조회
kafka-topics.bat --list --bootstrap-server [브로커엔드포인주소]:[포트] --command-config C:\kafka_2.13-3.6.1\config\client.properties
토픽 삭제
kafka-topics.bat --bootstrap-server [브로커엔드포인주소]:[포트] --delete --topic [토픽이름] --command-config C:\kafka_2.13-3.6.1\config\client.properties
토픽 생성
kafka-topics.bat --bootstrap-server [브로커엔드포인주소]:[포트] --create --topic [토픽이름] --partitions [개수] --replication-factor [개수] --command-config C:\kafka_2.13-3.6.1\config\client.properties
토픽 구성정보 조회
kafka-topics.bat --topic [토픽이름] --describe --bootstrap-server [브로커엔드포인주소]:[포트] --command-config C:\kafka_2.13-3.6.1\config\client.properties
토픽의 record 조회
kafka-console-consumer.bat --bootstrap-server [브로커엔드포인주소]:[포트] --topic [토픽이름] --from-beginning --consumer.config C:\kafka_2.13-3.6.1\config\client.properties --property print.offset=true --property print.timestamp=true --property print.key=true
토픽에 메세지 발행
kafka-console-producer.bat --topic order-status --bootstrap-server b-2.mskdominos.ormjxv.c2.kafka.ap-northeast-2.amazonaws.com:9098 --producer.config C:\kafka_2.13-3.6.1\config\client.properties
클러스터에 연결된 컨슈머 그룹 리스트 조회
kafka-consumer-groups.bat --bootstrap-server [브로커엔드포인주소]:[포트] --command-config C:\kafka_2.13-3.6.1\config\client.properties --list
amazon.msk.canary.group.broker-1
컨슈머 그룹 오프셋 정보 조회
kafka-consumer-groups.bat --bootstrap-server [브로커엔드포인주소]:[포트] --command-config C:\kafka_2.13-3.6.1\config\client.properties --describe --group [그룹이름] --offsets