毗连远程的kafka【linux】

前言

2024-5-14 18:45:48
以下内容源自《【linux】》
仅供学习交流使用
版权

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

远程客户端毗连Kafka
毗连远程的kafka【linux】

一、开放防火墙端口

阿里云服务器

远程服务器使用这个命令

1. netstat -tuln

复制代码

二、当地测试是否能访问端口

当地使用这个命令

1. nmap -p 9092 47.109.136.73

复制代码

1. PS E:\environment\kafka_2.12-2.3.0\bin\windows> nmap -p 9092 47.109.136.73
2. 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 completelyStarting Nmap 7.93 ( https://nmap.org ) at 2024-05-14 18:48 中国尺度时间Nmap scan report for 47.109.136.73Host is up (0.017s latency).PORT     STATE SERVICE9092/tcp open  XmlIpcRegSvcNmap done: 1 IP address (1 host up) scanned in 0.43 seconds

复制代码

可以看到open

如果是filtered，就是不可

三、远程kafka设置

1. vim /config/server.properties

复制代码

这两个好像会冲突，开启一个就行

1. #listeners=PLAINTEXT://localhost:9092  
3. advertised.listeners=PLAINTEXT://47.109.136.73:9092

复制代码

四、开启远程kakfa

最好照旧进入到kakfa目次下，运行

1. # 进入目录
2. cd /opt/kafka_2.12-2.3.0/
3. # 启动zookeeper
4. bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
5. # 启动kafka
6. nohup bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 &
7. # 查看主题
8. bin/kafka-topics.sh --list --bootstrap-server localhost:9092
11. # 关闭kafka
12. bin/kafka-server-stop.sh
13. # 关闭zookeeper
14. bin/zookeeper-server-stop.sh

复制代码

远程测试

1. bin/kafka-topics.sh --list --bootstrap-server localhost:9092

复制代码

五、当地测试能否毗连远程

进入到kafka的window目次下
运行命令

1. .\kafka-topics.bat --list --bootstrap-server 47.109.136.73:9092

复制代码

1. PS E:\environment\kafka_2.12-2.3.0\bin\windows> .\kafka-topics.bat --list --bootstrap-server 47.109.136.73:9092
2. __consumer_offsetsappointmentcalendarinformationopinionreply_appointmentreply_calendarreply_informationreport

复制代码

六、SpringBoot测试毗连

1. @SpringBootTest
2. public class ConnTest {
3.     @Autowired
4.     private KafkaTemplate<String, String> kafkaTemplate;
6.     @Test
7.     public void testKafkaConnection() {
8.         try {
9.             kafkaTemplate.send("testTopic", "testMessage");
10.             System.out.println("Kafka connection successful");
11.         } catch (Exception e) {
12.             System.err.println("Failed to connect to Kafka: " + e.getMessage());
13.         }
14.     }
15. }

复制代码

效果显示

碰到的标题

如果这两个设置同时开启，如下

就会碰到这个标题

最后

2024-5-14 19:01:14
迎着日光月光星光，直面风霜雨霜雪霜。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。