카프카2 [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 다음