Skip to content
whiletrue edited this page Sep 2, 2016 · 14 revisions

现在已有的公共插件:

inputs: Kafka Stdin Tcp(mina实现) Netty(netty 实现) Beats

filters: Add DateISO8601 IpIp Grok Gsub Json KV Lowercase Remove Rename Replace Trim UA Uppercase URLDecode

outputs: Elasticsearch File Kafka Performance(记录一段时间内处理的记录数) Stdout

jar放置目录(编译的jar必须要有版本号 ): jlogstash 核心代码放在jlogstash/lib/下 插件的代码分别的放到jlogstash/plugin 下的filter,input,output目录下

jlogstash 启动参数:

-f:配置文件 yaml格式路径

-l:日志文件路径

-w:filter和output 线程数 默认是根据的机器去的cpu核数

-q:input quene size 默认是 1000

-v: info级别

-vv:debug级别

-vvv:trace级别

Clone this wiki locally