Flume 组件（source、channel、sink）远程调试

我就是我 2023-02-20 06:47 57阅读 0赞

1.创建Maven工程

2.编写所需要自定义组件的代码（以Source为例）,打包放到服务器上

在这里插入图片描述

3.添加idea Debug 配置

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

4.在服务器上广播Debug端口

  1. [atguigu@hadoop102 flume]$ export FLUME_JAVA_OPTS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005"

提示：这里需要将suspend=n，改为suspend=y.

5.启动Flume 程序，测试连接

  1. [atguigu@hadoop102 flume ]$ flume-ng agent -c conf/ -f jobs/mysource.conf -n a1 -Dflume.root.logger=INFO,console

在这里插入图片描述

6.进入Idea 进行Debug操作

在这里插入图片描述

7.取消端口的广播

  1. [atguigu@hadoop102 flume]$ export  -n FLUME_JAVA_OPTS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005"

发表评论

表情：
评论列表 （有 0 条评论，57人围观）

还没有评论，来说两句吧...

相关阅读