Kafka가 이미 기동된 환경에서 토픽과 메시지 흐름을 확인하는 CLI 절차입니다. 원노트의 kafka-topic.sh 오타를 kafka-topics.sh로 수정했습니다. 원본의 ZooKeeper 기반 설치 기록은 새 버전의 권장 설치 절차로 확장하지 않고 명령 사용만 정리했습니다.
브로커와 토픽 조회
Kafka 배포 디렉터리의 bin 아래에서 실행합니다. 예시는 loopback의 19092 포트입니다. 원격 환경은 advertised.listeners가 클라이언트에서 도달 가능한 주소를 반환하는지 확인합니다.
bin/kafka-topics.sh --bootstrap-server 127.0.0.1:19092 --list
bin/kafka-topics.sh --bootstrap-server 127.0.0.1:19092 --describe --topic test-topic실습 토픽 생성
단일 브로커 실습의 replication-factor 1은 복제 이중화가 없습니다. 운영에서는 브로커 수, 복제 계수, min.insync.replicas와 producer acks를 함께 설계합니다. 기존 운영 토픽과 이름이 겹치지 않도록 합니다.
bin/kafka-topics.sh --create --topic test-topic --partitions 1 --replication-factor 1 --bootstrap-server 127.0.0.1:19092
bin/kafka-console-producer.sh --topic test-topic --bootstrap-server 127.0.0.1:19092입력한 한 줄이 메시지로 전달되는지 별도 터미널의 consumer에서 확인합니다. --from-beginning은 보관 중인 이전 메시지부터 읽도록 요청합니다.
bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server 127.0.0.1:19092인증 환경의 옵션 구분
관리 명령은 --command-config, consumer는 --consumer.config, producer는 --producer.config로 클라이언트 설정 파일을 지정합니다. AWS MSK IAM을 쓰면 해당 인증 라이브러리·IAM 권한·SASL_SSL 설정이 함께 필요합니다. 실제 브로커 주소와 인증 값을 매뉴얼에 복사하지 않습니다.
삭제 명령은 토픽 데이터를 제거하므로 실습 토픽과 사용자가 없는지 확인한 뒤에만 실행합니다. 연결 성공만으로 인증·토픽 권한까지 정상이라고 판단하지 않고 각 단계의 오류를 나눠 확인합니다.