消息队列MQ

Kafka的简单使用

本文主要是介绍Kafka的简单使用，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

下面目的主要是进行简单测试kafka，比如在其他网络中已提供了IP和地址，进行kafka的读取，自已不想再写代码:
环境要求：存在java环境：

1、下载Kafka的程序 https://kafka.apache.org/downloads
2、将代码解压。
3、执行消息命令。
bin/kafka-console-consumer.sh --topic AUDI_APP_AUDIENCE_DEV --from-beginning --bootstrap-server 172.20.133.21:9092
4、执行发送命令。
bin/kafka-console-producer.sh --topic AUDI_APP_AUDIENCE_DEV --bootstrap-server 172.20.133.21:9092

注意：执行过程中会出现找不到Java目录的情况，请确认$JAVA_HOME位置是否正确。
kafka-run-class.sh: line 342: exec: /Library/Java/JavaVirtualMachines/jdk-11.0.10.jdk/Contents/Home/

官网：
https://kafka.apache.org/quickstart

这篇关于Kafka的简单使用的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航