标签：生产者 发送 star nbsp produce 操作 -- rom code
kafka教程，完全参照w3school:
https://www.w3cschool.cn/apache_kafka/apache_kafka-dac11yot.html
以下是入门学习过程中摘录的一些操作
cd /usr/software/kafka 启动ZooKeeper bin/zookeeper-server-start.sh config/zookeeper.properties 要启动Kafka Broker bin/kafka-server-start.sh config/server.properties 创建Kafka主题 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Hello-Kafka 主题列表 bin/kafka-topics.sh --list --zookeeper localhost:2181 启动生产者以发送消息 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka 启动消费者 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic Hello-Kafka --from-beginning
备注：producer启动好了之后，可以在producer console下输入任意信息（发布消息）
然后消息会发送到broker，然后就可以在consumer 端接收数据，包括离线数据
标签：生产者 发送 star nbsp produce 操作 -- rom code
原文地址：https://www.cnblogs.com/xiaoliu66007/p/9745298.html
