kafka命令
主题
创建主题（复制因子数量不能大于broker数量）
./kafka-topics.sh --zookeeper localhost:2181 --create --partitions 3 --replication-factor 1 --topic test01
删除主题
./kafka-topics.sh --delete --zookeeper localhost:2181 --topic test01
查看所有主题
./kafka-topics.sh --list --zookeeper localhost:2181
查看某个主题
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic track.data.receive
分组
查看所有分组
./kafka-consumer-groups.sh --bootstrap-server 192.168.164.129:9092 --list
查看分组offset
./kafka-consumer-groups.sh --bootstrap-server 192.168.164.129:9092 --describe --group Device_Track_Date
查看分组成员占有分区数量
./kafka-consumer-groups.sh --bootstrap-server 192.168.164.129:9092 --describe --members --group Device_Track_Date
查看分组成员占有的分区
./kafka-consumer-groups.sh --bootstrap-server 192.168.164.129:9092 --describe --group Device_Track_Date --members --verbose
删除一个或多个分组(删除分组后再注册相同分组，会重新消费)
./kafka-consumer-groups.sh --bootstrap-server 192.168.164.129:9092 --delete --group A --group B
分区
修改分区数量（5分区）（分区数只能增加，不能减少）
./kafka-topics.sh --zookeeper localhost:2181 -alter --partitions 5 --topic test01
复制因子
修改复制因子数量
cat << EOF > increase-replication-factor.json
{"version":1,
"partitions":[
{"topic":"test01","partition":0,"replicas":[0,1,2]},
{"topic":"test01","partition":1,"replicas":[0,1,2]},
{"topic":"test01","partition":2,"replicas":[0,1,2]},
]
}
EOF
./kafka-reassign-partitions.sh --zookeeper 192.168.164.01:2181,192.168.164.02:2181,192.168.164.03:2181 --reassignment-json-file increase-replication-factor.json --execute
|