Kafka_命令经验集_./kafka-topics.sh --zookeeper 107.96.3.236:2181 --

1. 查看所有 topic 列表

./kafka-topics.sh --zookeeper {ip}:2181 --list

2. 创建 topic 主题

./kafka-topics.sh --create --zookeeper {ip}:2181 --replication-factor 1 --partitions 1 --topic {topic_name}

3. 创建生产者消息

./kafka-console-producer.sh --broker-list {ip}:9093 --topic {topic_name}

4. 查看 topic 消息

./kafka-console-consumer.sh --bootstrap-server {ip}:9093 --topic {topic_name} --from-beginning

5.清除 kafka 组消息

./kafka-consumer-groups.sh --bootstrap-server {ip}:9093 --group {group_name} --topic {topic_name} --reset-offsets --to-earliest --execute