跳到主要内容

命令

2025年02月23日
柏拉文
越努力，越幸运

一、启动​

kafka-server-start /opt/homebrew/etc/kafka/server.properties

二、停止​

kafka-server-stop

三、主题​

3.1 创建主题​

使用 kafka-topics.sh 创建一个名为 test-topic 的主题

kafka-topics --create --topic test-topic --bootstrap-server localhost:29092 --partitions 3 --replication-factor 1

3.2 获取主题​

列出所有主题

kafka-topics --list --bootstrap-server localhost:29092

3.3 删除主题​

kafka-topics --delete --topic test-topic --bootstrap-server localhost:29092

3.4 查看主题​

kafka-topics --describe --topic test-topic --bootstrap-server localhost:29092

3.5 查看主题描述信息​

kafka-topics --describe --topic kafka-topic-test --bootstrap-server localhost:29092

四、生产者​

4.1 发送消息​

运行 Kafka 生产者, 发送消息

kafka-console-producer --topic test-topic --bootstrap-server localhost:29092

然后输入消息

Hello Kafka
Kafka is running!

按 Ctrl + C 退出。

五、消费者​

5.1 消费消息​

运行 Kafka 消费者

kafka-console-consumer --topic test-topic --from-beginning --bootstrap-server localhost:29092

如果之前发送了 Hello Kafka，可以看到

Hello Kafka
Kafka is running!

按 Ctrl + C 退出。