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 |