连接远程的kafka【linux】

# 连接远程的kafka【linux】

前言

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  XmlIpcRegSvc

Nmap 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
# 启动kafkanohup 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测试连接

@SpringBootTestpublicclassConnTest{@AutowiredprivateKafkaTemplate<String,String> kafkaTemplate;@TestpublicvoidtestKafkaConnection(){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

迎着日光月光星光，直面风霜雨霜雪霜。