filebeat tcp input to elasticsearch

filebeat.yaml:

filebeat.inputs:
- type: tcp
  enable: true
  host: "0.0.0.0:9400"

processors:
  - decode_json_fields:
      fields: ['message']
      target: ""
      overwrite_keys: true
  - drop_fields:
     fields: ['message', 'ecs', 'agent', log]

output.elasticsearch:
  hosts: ["192.168.10.10:59200"]
  index: "test"

setup.template.enabled: false
setup.ilm.enabled: auto

接收tcp输入json格式数据
代替logstash，减少系统负担
自定义输出到elasticsearch index

手动发送数据测试
echo -e '{"method":"HelloService.Hello","params":["hello"],"id":1}'| nc -v 192.168.10.10 9400

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容