文章出處
文章列表
在Centos上安裝和部署完成kafka之后，我們就可以向服務端推消息和消費它了，今天主要聊幾個常用的命令，比建立topic,從broken顯示所有topics列表，向broken發消息，從broken拉消息等。
- 建立topic
- 列出所有topic
- 向broken推消息
- 從broken拉消息
建立topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 我的Topic
列出所有topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
向broken推消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic lind66
從broken拉消息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
上面幾個命令是最基本的命令行指令，我們需要掌握它。
文章列表
全站熱搜
留言列表
