做网站 信息集成过程的顺序,贵阳网站seo公司,西安网站推广招聘,梵克雅宝官网编号查询# 连接远程的kafka【linux】 前言版权推荐连接远程的kafka【linux】一、开放防火墙端口二、本地测试是否能访问端口三、远程kafka配置四、开启远程kakfa五、本地测试能否连接远程六、SpringBoot测试连接 遇到的问题最后 前言
2024-5-14 18:45:48
以下内容源自《【linux】》 仅… # 连接远程的kafka【linux】 前言版权推荐连接远程的kafka【linux】一、开放防火墙端口二、本地测试是否能访问端口三、远程kafka配置四、开启远程kakfa五、本地测试能否连接远程六、SpringBoot测试连接 遇到的问题最后 前言
2024-5-14 18:45:48
以下内容源自《【linux】》 仅供学习交流使用
版权
禁止其他平台发布时删除以下此话 本文首次发布于CSDN平台 作者是CSDN日星月云 博客主页是https://jsss-1.blog.csdn.net 禁止其他平台发布时删除以上此话
推荐
远程客户端连接Kafka
连接远程的kafka【linux】
一、开放防火墙端口
阿里云服务器
远程服务器使用这个命令
netstat -tuln二、本地测试是否能访问端口
本地使用这个命令
nmap -p 9092 47.109.136.73PS E:\environment\kafka_2.12-2.3.0\bin\windows nmap -p 9092 47.109.136.73
WARNING: Could not import all necessary Npcap functions. You may need to upgrade to the latest version from https://npcap.com. Resorting to connect() mode -- Nmap may not function completely
Starting Nmap 7.93 ( https://nmap.org ) at 2024-05-14 18:48 中国标准时间
Nmap scan report for 47.109.136.73
Host is up (0.017s latency).PORT STATE SERVICE
9092/tcp open XmlIpcRegSvcNmap done: 1 IP address (1 host up) scanned in 0.43 seconds可以看到open 如果是filtered就是不行
三、远程kafka配置
vim /config/server.properties这两个好像会冲突开启一个就行
#listenersPLAINTEXT://localhost:9092 advertised.listenersPLAINTEXT://47.109.136.73:9092四、开启远程kakfa
最好还是进入到kakfa目录下运行
# 进入目录
cd /opt/kafka_2.12-2.3.0/
# 启动zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 启动kafka
nohup bin/kafka-server-start.sh config/server.properties 1/dev/null 21
# 查看主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092# 关闭kafka
bin/kafka-server-stop.sh
# 关闭zookeeper
bin/zookeeper-server-stop.sh远程测试
bin/kafka-topics.sh --list --bootstrap-server localhost:9092五、本地测试能否连接远程
进入到kafka的window目录下
运行命令
.\kafka-topics.bat --list --bootstrap-server 47.109.136.73:9092PS E:\environment\kafka_2.12-2.3.0\bin\windows .\kafka-topics.bat --list --bootstrap-server 47.109.136.73:9092
__consumer_offsets
appointment
calendar
information
opinion
reply_appointment
reply_calendar
reply_information
report六、SpringBoot测试连接
SpringBootTest
public class ConnTest {Autowiredprivate KafkaTemplateString, String kafkaTemplate;Testpublic void testKafkaConnection() {try {kafkaTemplate.send(testTopic, testMessage);System.out.println(Kafka connection successful);} catch (Exception e) {System.err.println(Failed to connect to Kafka: e.getMessage());}}
}结果显示 遇到的问题
如果这两个配置同时开启如下
就会遇到这个问题
最后
2024-5-14 19:01:14
迎着日光月光星光直面风霜雨霜雪霜。
