命令
- 启动
nohup bin/kafka-server-start.sh config/server.properties &
- 显示 topic
bin/kafka-topics.sh --list --zookeeper 172.16.8.28:39181
- 新建 topic
bin/kafka-topics.sh --create --zookeeper 172.16.8.28:39181 --replication-factor 1 --partitions 1 --topic SysbacklogFinishTopic
kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic smccheckkafka --zookeeper 10.1.130.84:49181,10.1.130.85:49181,10.1.236.122:49181/kfk
- 发送消息
bin/kafka-console-producer.sh --broker-list 172.16.8.28:9092 --topic SysbacklogCreateTopic
- 控制台打印消息
bin/kafka-console-consumer.sh --zookeeper 172.16.8.28:39181 --from-beginning --topic KefuCreateTopic
新版本:
bin/kafka-console-consumer.sh --bootstrap-server 172.16.13.121:9092 --from-beginning --topic SysbacklogCreateTopic
bin/kafka-topics.sh --describe --zookeeper 172.16.8.28:39181 --topic SysbacklogCreateTopic
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于