kafka教程,完全参照w3school:
https://www.w3cschool.cn/apache_kafka/apache_kafka-dac11yot.html
以下是入门学习过程中摘录的一些操作
cd /usr/software/kafka启动ZooKeeperbin/zookeeper-server-start.sh config/zookeeper.properties要启动Kafka Brokerbin/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 端接收数据,包括离线数据
Apache Kafka 概述
原文地址:https://www.cnblogs.com/xiaoliu66007/p/9745298.html