连接远程的kafka【linux】

# 连接远程的kafka【linux】

前言
版权
推荐
连接远程的kafka【linux】
- 一、开放防火墙端口
- 二、本地测试是否能访问端口
- 三、远程kafka配置
- 四、开启远程kakfa
- 五、本地测试能否连接远程
- 六、SpringBoot测试连接
遇到的问题
最后

前言

2024-5-14 18:45:48

以下内容源自《【linux】》
仅供学习交流使用

版权

禁止其他平台发布时删除以下此话
本文首次发布于CSDN平台
作者是CSDN@日星月云
博客主页是https://jsss-1.blog.csdn.net
禁止其他平台发布时删除以上此话

连接远程的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
# 启动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 {
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Test
    public 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());
        }
    }
}