Kafka数据迁移
LiuSw Lv6

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 分区数量
 评论