Kafka_命令经验集
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
上一篇：
MySQL 更新执行流程
下一篇：
浙政钉2.0免登