安阳 做网站seo中介平台
# 连接远程的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.73
PS 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
这两个好像会冲突，开启一个就行
#listeners=PLAINTEXT://localhost:9092 advertised.listeners=PLAINTEXT://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 2>&1 &
# 查看主题
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:9092
PS 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 KafkaTemplate<String, 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
迎着日光月光星光，直面风霜雨霜雪霜。