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

原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/282524.html

(0)
上一篇 2022年8月27日
下一篇 2022年8月27日

相关推荐

发表回复

登录后才能评论