그냥저냥 끄적이는 SE

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

root@msp-kafka01:~# /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server msp-kafka01:9092 --topic ds-topic --from-beginning

root@msp-kafka01:~# /usr/local/kafka/bin/kafka-console-producer.sh --broker-list msp-kafka01:9092 --topic ds-topic abc test

root@msp-kafka01:~# /usr/local/kafka/bin/kafka-topics.sh --zookeeper msp-zk01:2181/ds-kafka --topic ds-topic --delete

#!/bin/bash for TOPIC in `cat list` do /usr/local/kafka/bin/kafka-topics.sh --zookeeper msp-zk01:2181,msp-zk02:2181,msp-zk03:2181/msp-log --partitions 3 --replication-factor 2 --topic ${TOPIC} --create /usr/local/kafka/bin/kafka-topics.sh --zookeeper msp-zk01:2181,msp-zk02:2181,msp-zk03:2181/msp-log --alter --topic "$TOPIC" --config retention.ms=43200000 done list파일에는 토픽명을 넣어줌