Kafka数据迁移
Kafka数据迁移
进入kafka安装目录bin下执行以下操作
1 | cd /data/kafka/bin |
1.导出主题到本地
1 | ./kafka-console-consumer.sh --bootstrap-server 192.168.11.160:9092,192.168.11.161:9092,192.168.11.162:9092 --topic 主题名称 --from-beginning > /tmp/主题名称.txt |
2.查看主题,如果主题不存在,创建主题
2.1列出主题
1 | ./kafka-topics.sh --list --bootstrap-server 192.168.11.160:9092,192.168.11.161:9092,192.168.11.162:9092 |
2.2创建主题
1 | ./kafka-topics.bat --create --bootstrap-server 192.168.11.204:9092,192.168.11.205:9092,192.168.11.206:9092 --replication-factor 2 --partitions 3 --topic 主题名称 |
3.导入主题文件
1 | ./kafka-console-producer.sh --broker-list 192.168.11.204:9092,192.168.11.205:9092,192.168.11.206:9092 --topic 主题名称 < /tmp/主题名称.txt |
4.kafka增加分区(可不更改)
1 | ./kafka-topics.sh --alter --broker-list 192.168.11.204:9092,192.168.11.205:9092,192.168.11.206:9092 --topic 主题名称 --partitions 分区数量 |
评论