open source 설정 및 끄적/kafka

카프카 확장(replica 증설)

나한순간에 2021. 10. 23. 21:47
root@msp-kafka01:~# cat rf.json
{"version":1,

"partitions":[

    {"topic":"ds-topic","partition":0,"replicas":[1,2,3]}

]}
[run]
/usr/local/kafka/bin/kafka-reassign-partitions.sh --zookeeper msp-zk01:2181,msp-zk02:2181,msp-zk03:2181/ds-kafka --reassignment-json-file /root/rf.json --execute

'open source 설정 및 끄적 > kafka' 카테고리의 다른 글

kafka message 받기  (0) 2021.10.23
kafka topic 삭제  (0) 2021.10.23
kafka topic 생성  (0) 2021.10.23
filebeat를 통해 kafka로 전송하기  (0) 2021.03.16
omkafka  (0) 2021.03.01