将矿工利润主题副本从一个增加到三个replication.json{"version":1,"partitions":[{"topic":"miner-profit","partition":0,"replicas":[1,2,3]},{"topic":"miner-profit","partition":1,"replicas":[1,2,3]},{"topic":"miner-profit","partition":2、"replicas":[1,2,3]}]}执行命令../kafka1/bin/kafka-reassign-partitions.sh--zookeeperdev1.xiayu.com:2181,dev2.xiayu.com:2182,dev3.xiayu.com:2183--reassignment-json-filereplication.json--执行查看所有topics./kafka1/bin/kafka-topics.sh--list--zookeeperdev1.xiayu.com:2181,dev2.xiayu.com:2182,dev3.xiayu.com:2183创建主题./kafka1/bin/kafka-topics.sh--zookeeperdev1.xiayu.com:2181,dev2.xiayu.com:2182,dev3.xiayu.com:2183--create--replication-factor2--partitions2--topicuser-logindeletetopic./kafka1/bin/kafka-topics.sh--zookeeperdev1.xiayu.com:2181,dev2.xiayu.com:2182,dev3.xiayu.com:2183--delete--topicuser-regisger增加主题分区数./kafka1/bin/kafka-主题。sh--alter--zookeeperdev1.xiayu.com:2181,dev2.xiayu.com:2182,dev3.xiayu.com:2183--topicminer-profit--partitions3查看topic分区信息./kafka1/bin/kafka-topics.sh--describe--zookeeperdev1.xiayu.com:2181,dev2.xiayu.com:2182,dev3.xiayu.com:2183--topicminer-profit查看一个topic中的所有消息./kafka1/bin/kafka-console-consumer.sh--bootstrap-serverdev1.xiayu.com:9092,dev2.xiayu.com:9093,dev3.xiayu.com:9094--topicminer-profit--from-beginning查看所有消费者groups./kafka1/bin/kafka-consumer-groups.sh--list--bootstrap-serverdev1.xiayu.com:9092,dev2.xiayu.com:9093,dev3.xiayu.com:9094查看消费Consumer组消费。/kafka1/bin/kafka-consumer-groups.sh--bootstrap-serverdev1.xiayu.com:9092,dev2.xiayu.com:9093、dev3.xiayu.com:9094--groupxiayu-consumer-group--describecmak启动./cmak-3.0.0.5/bin/cmak-Dconfig.file=./cmak-3.0.0.5/conf/application.conf-Dhttp.port=8333
