副本的作用是保证数据的高可用，一个副本在一个broker节点上，broker就是一个台机器或者一个kafka实例，当某个副本出现故障后，还可以使用其他副本的数据，如果只有一个副本，那么就无法保证高可用。
myip="10.252.4.90"
# 创建TOPIC 版本 < 2,2 --bootstrap-server ${myip}:9092 换成 --zookeeper ${myip}:2181
./kafka-topics.sh --create --bootstrap-server ${myip}:9092 --replication-factor 1 --partitions 1 --topic test
# 查看 kafka 所有 topic
./kafka-topics.sh --bootstrap-server ${myip}:9092 --list
# 删除topic
./kafka-topics.sh --delete --bootstrap-server ${myip}:9092 --topic test
# 修改 partitions
./kafka-topics.sh --bootstrap-server ${myip}:9092 --alter --topic test --partitions 2
# 查看topic详情
./kafka-topics.sh --bootstrap-server ${myip}:9092 --describe --topic test
# 显示所有的组
./kafka-consumer-groups.sh --bootstrap-server ${myip}:9092 --all-groups --list
# 查看消费组的消费情况
./kafka-consumer-groups.sh --bootstrap-server ${myip}:9092 --group python-consumer --describe
# 删除消费组（前提是没有在消费的）
./kafka-consumer-groups.sh --bootstrap-server ${myip}:9092 --group python-consumer --delete
# 生产者
./kafka-console-producer.sh --topic test --broker-list ${myip}:9092
# 消费者
./kafka-console-consumer.sh --bootstrap-server 10.252.4.90:9092:9092,10.252.4.91:9092:9092,10.252.4.92:9092 --from-beginning --topic test
