发布于2024-12-04 阅读(0)
扫一扫,手机访问
1. 安装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
目录。./kafka-version.sh
示例输出
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
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店