1. 安装Kafka
KAFKA_HOME
为Kafka安装目录。KAFKA_HOME
为Kafka安装目录。2. 启动ZooKeeper
$KAFKA_HOME/bin
目录。./zookeeper-server-start.sh config/zookeeper.properties
3. 启动Kafka服务器
$KAFKA_HOME/bin
目录。./kafka-server-start.sh config/server.properties
4. 创建主题
$KAFKA_HOME/bin
目录。./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1
5. 发送消息
$KAFKA_HOME/bin
目录。./kafka-console-producer.sh --topic my-topic --message "Hello, world!"
6. 消费消息
$KAFKA_HOME/bin
目录。./kafka-console-consumer.sh --topic my-topic --from-beginning
7. 查询版本
$KAFKA_HOME/bin
ZooKeeper是Kafka的依赖项,因此在启动Kafka之前必须先启动它。
🎜打开命令行终端并导航到$KAFKA_HOME/bin
目录。🎜🎜运行以下命令启动ZooKeeper:🎜🎜./kafka-version.sh🎜🎜3. 启动Kafka服务器🎜🎜🎜🎜打开命令行终端并导航到
$KAFKA_HOME/bin
目录。🎜🎜运行以下命令启动Kafka服务器:🎜🎜kafka-version.sh: version: 2.8.0 kafka-version: 2.8.0 kafka-storage: 2.8.0 kafka-clients: 2.8.0 kafka-streams: 2.8.0 kafka-connect: 2.8.0 kafka-admin: 2.8.0 kafka-tools: 2.8.0🎜🎜4. 创建主题🎜🎜🎜🎜主题是Kafka中数据的逻辑分组。🎜🎜要创建主题,请打开命令行终端并导航到
$KAFKA_HOME/bin
目录。🎜🎜运行以下命令创建主题:🎜🎜rrreee🎜🎜5. 发送消息🎜🎜🎜🎜要向主题发送消息,请打开命令行终端并导航到$KAFKA_HOME/bin
目录。🎜🎜运行以下命令发送消息:🎜🎜rrreee🎜🎜6. 消费消息🎜🎜🎜🎜要消费主题的消息,请打开命令行终端并导航到$KAFKA_HOME/bin
目录。🎜🎜运行以下命令消费消息:🎜🎜rrreee🎜🎜7. 查询版本🎜🎜🎜🎜要查询Kafka服务器的版本,请打开命令行终端并导航到$KAFKA_HOME/bin
目录。🎜🎜运行以下命令查询版本:🎜🎜rrreee🎜🎜示例输出🎜🎜rrreee以上是学会使用Kafka版本查询的逐步指南的详细内容。更多信息请关注PHP中文网其他相关文章!