Flume监听端口，输出端口数据案例

1、在flume目录下新建/myconf目录,并在目录下新建socket-console.conf 文件！

mkdir myconf
cd myconf
touch socket-console.conf

2、编辑文件vim socket-console.conf，添加以下内容：

# 定义这个agent中各组件的名字
a1.sources = r1
a1.sinks = k1
a1.channels = c1# 描述和配置source组件：r1
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444# 描述和配置sink组件：k1
a1.sinks.k1.type = logger# 描述和配置channel组件，此处使用是内存缓存的方式
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100# 描述和配置source  channel   sink之间的连接关系
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1

3、运行命令 bin/flume-ng agent --conf conf/ --name a1 --conf-file myconf/socket-console.conf -Dflume.root.logger==INFO,console

其中-Dflume.root.logger==INFO,console的意思是将日志打印在控制台上

4、新建一个终端页面进入44444端口nc localhost 44444,并输入测试信息

可以看到在flume服务端上已经打印出了相关的信息！！

PS：flume的启动命令可以使用以下两种方式

bin/flume-ng agent --conf conf --conf.file example.conf --name a1 -Dflume.root.logger=INFO,console
bin/flume-ng agent -n $agent_name -c conf -f conf/flume-conf.properties.template

Flume监听端口，输出端口数据案例相关推荐

flume监听服务器文件,flume监听服务器端口数据库
flume监听服务器端口数据库内容精选换一换本章节为您介绍以下内容:准备弹性云服务器作为GDS服务器在使用GDS导入导出数据之前,需要准备一台或多台与GaussDB(DWS) 集群在相同VPC内 ...
用伪分布式处理爬取下来的数据并用flume监听hive分析，sqoop传入MySQL并可视化
一.爬虫部分(爬取了前程无忧和中华英才网,此处就拿前程无忧为例) 创建爬虫 scrapy startproject wyjob scrapy genspider job'www.51jobs.com' ...
linux监听端口命令
在linux系统下,我们可以通过相关的命令监听端口的状态.下面由学习啦小编为大家整理了linux监听端口命令的相关知识,希望对大家有所帮助. 一.linux监听端口命令--nc命令详解语法 nc [ ...
linux监听一个端口命令,linux监听端口命令
在linux系统下,我们可以通过相关的命令监听端口的状态.下面由学习啦小编为大家整理了linux监听端口命令的相关知识,希望对大家有所帮助. 一.linux监听端口命令--nc命令详解语法 nc [ ...
java 监听端口_java游戏服务器检查报告（经验分享）
java在centos系统运行,经过大量用户使用后,我们使用那些监听手段来判断服务器是否达到我们理想要求呢,判断服务器使用可以继续使用呢? 我们以进程PID9496(监听端口:9624)为对象说明,启 ...
netstat linux查看监听端口号,linux用netstat查看服务及监听端口
[root@localhost ~]# netstat -nlp netstat命令各个参数说明如下: -t : 指明显示TCP端口 -u : 指明显示UDP端口 -l : 仅显示监听套接字(所谓套接 ...
Flume监听多个文件目录，并根据文件名称不同，输出到kafka不同topic中
一.Flume监听多个文件目录 1. flume的环境搭建和基础配置参考 https://blog.csdn.net/qinqinde123/article/details/128130131 2. ...
socket监听端口实现实时通讯
socket通信的原理在这里就不说了,它的用途还是比较广泛的,我们可以使用socket来做一个API接口出来,也可以使用socket来实现两个程序之间的通信,我们来研究一下在php里面如何实现sock ...
zabbix自动发现规则实现批量监控主机的TCP监听端口
检查服务器所有监听端口和其对应的服务名称的脚本可以参考https://blog.zzyyxx.top/blog/post/gordy/acf57f04f9e1 现在准备加入zabbix自动发现规则并 ...

Flume监听端口，输出端口数据案例

Flume监听端口，输出端口数据案例相关推荐

最新文章

热门文章