在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
上面几个命令是最基本的命令行指令,我们需要掌握它。