본문 바로가기

KAFKA

kafka-topics.sh 파라미터 설명 kafka-topics.sh의 도움말 해석입니다. (0.10.2 기준) 의역이나 오역이 있을 수 있습니다. --alter: 토픽의 파티션 수나 복제 개수를 변경 --config : 이미 만들어져 있는 토픽의 설정을 오버라이드 --create: 새로운 토픽 생성 --delete: 토픽 삭제 --delete-config : 삭제 될 토픽의 설정 오버라이드 --describe: 토픽의 상세 정보 출력 --force: 강제로 명령 실행 --help: 도움말 출력 --if-exists: 토픽을 지우거나 수정할 때 토픽이 존재하는지 먼저 검사 --if-not-exists: 토픽을 생성할 때 토픽이 존재하지 않을때만 실행 --list: 사용가능한 모든 토픽의 목록을 출력 --partitions : 생성되거나 수정될 ..
[Tip] Producer, Consumer에서 Kafka에 접속되지 않을 때 Kafka 클러스터를 구축하고 나서 보통 kafka-console-producer.sh와 kafka-console-consumer.sh를 이용하여 Kafka 클러스터가 정상적으로 구축되었는지 확인하곤 합니다. kafka-console-producer.sh와 kafka-console-consumer.sh를 통해서 정상적으로 메시지를 생성하고 소비하는 것을 확인했지만 정작 다른 장비(또는 네트워크)에 있는 Logstash의 output 또는 직접 API를 이용하여 개발한 Producer / Consumer에서 Kafka 클러스터와 통신을 하지 못하는 경우에는 다음과 같은 사항을 확인해보기 바랍니다. 요즘은 Docker나 클라우드 서비스를 사용하면서 Kafka가 구동되고 있는 장비가 Floating IP를 가..