java -version
如图所示我已安装
没有安装的可以参考以下链接
链接: https://blog.csdn.net/qq_42985046/article/details/110928273
tar -xzf kafka_2.11-0.11.0.3.tgz mv kafka_2.11-0.11.0.3 kafka cd kafka
//主要修改以下几点 listeners=PLAINTEXT://服务器IP:9092 zookeeper.connect=服务器IP:2181 log.dirs=对应的你想存放的log文件夹目录3.启动kafka（切记先启动zookeeper再启动kafka）
启动zookeeper
启动kafka
命令如下：
/usr/local/kafka/bin/zookeeper-server-start.sh -daemon /usr/local/kafka/config/zookeeper.properties /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties jps
最终结果如图显示已经成功
./bin/kafka-topics.sh --create --topic helloworld --partitions 3 --replication-factor 1 --zookeeper localhost:21812.向topic里生产消息
./bin/kafka-console-producer.sh --broker-list 服务器的IP:9092 --topic helloworld3.消费消息
./bin/kafka-console-consumer.sh --bootstrap-server 服务器的IP:9092 --topic helloworld --from-beginning
至此结束
参考链接
链接: https://kafka.apache.org/quickstart
