Old Posts/Kafka3 [Kafka] 카프카 버전 확인 방법 카프카 2.0 이상의 경우 버전을 확인하기 위해서 kafka-topics.sh을 이용하면 된다. (KIP-278) $ kafka-topics.sh --version 물론 kafka-topics.sh의 버전과 브로커 버전이 다를 수도 있다. 혹은 옛날 버전의 카프카라면 --version 옵션이 지원되지 않기 때문에 조금 다른 방법을 이용해야 한다. $ cd $KAFKA_HOME $ find ./libs/ -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*' 카프카가 설치된 디렉토리로 가서 libs 디렉토리를 확인해보면 kafka_2.10-0.8.2-beta.jar 같은 파일이 있다. 여기서 2.10은 스칼라 버전을 의미하고, 0.8.2-beta에 해당하는 정보가 카프.. 2021. 12. 15. [Kafka] 토픽의 Replication Factor 변경 카프카 토픽에 전송된 메시지는 가용성을 위해서 여러 브로커에 복제되어 저장된다. 브로커 노드에 장애가 생긴 상황에서도 메시지 서비스가 가능하도록 하기 위함이다. 카프카는 이렇게 복제된 메시지를 Replica라고 부르며 몇 개의 Replica로 복제 할 것인지를 Replication Factor(RF)라고 한다. 수동으로 토픽을 생성할 때 옵션으로 RF 값을 명시할 수 있다. $ kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 2 --partitions 10 --topic MyTopic --replication-factor 옵션으로 몇 개의 Replica로 저장할지 지정할 수 있다. 만약 auto.create.t.. 2021. 10. 21. [Kafka] 카프카 자주 사용하는 명령어 카프카 클러스터를 운영하다보면 몇 가지 자주 사용하는 명령어들이 있다. 대부분 kafka-topic.sh 같은 스크립트를 이용한 쉘 명령어다. 토픽 생성 카프카 토픽은 kafka-topics.sh 스크립트를 이용해서 생성할 수 있다. $ kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 2 --partitions 10 --topic MyTopic 사용된 옵션은 다음과 같다. --create : 토픽 생성을 하겠다 --bootstrap-server : 토픽 생성을 위해 붙을 브로커 주소 --replication-facotr : 리플리케이션 팩터, 데이터를 몇 카피나 저장할지 --partitions : 토픽의 파티션.. 2021. 10. 6. 이전 1 다음