filebeat output.kafka 仅发送选定字段-Go服务器开发

在Filebeat的配置文件中，可以使用processors选项来处理事件数据。如果你只想发送选定字段到Kafka，你可以使用drop_fields或include_fields处理器来实现。

使用drop_fields处理器：在filebeat.inputs部分下添加一个processors段，并指定要删除的字段：

filebeat.inputs:
  - type: log
    paths:
      - /path/to/log/file.log
    processors:
      - drop_fields:
          fields: ["field1", "field2"]

上述配置将从事件数据中删除名为”field1”和”field2”的字段。

使用include_fields处理器：在filebeat.inputs部分下添加一个processors段，并指定要保留的字段：

filebeat.inputs:
  - type: log
    paths:
      - /path/to/log/file.log
    processors:
      - include_fields:
          fields: ["field1", "field2"]

上述配置将仅保留名为”field1”和”field2”的字段，并丢弃其他字段。

请根据你的需求选择适合的处理器，并根据实际情况进行相应调整。

内容由零声教学AI助手提供，问题来源于学员提问

filebeat output.kafka 仅发送选定字段

golang云原生

diff --git a/mtk/package/kernel/wlan_driver/gen4m/mt6639_driver/os/linux/gl_kal.c b/mtk/package/kernel/wlan_driver/gen4m/mt6639_driver/os/linux/gl_kal.c 解释此命令

git 如何把更改提交到本地

执行什么命令可以输出 git diff 命令的输出片段，显示两个文件之间的差异

raco@ubuntu_2204:~/data/mtk_code/T830/T830/openwrt/build_dir/target-aarch64-openwrt-linux-musl_musl/linux-gem6xxx_evb6990_cpe_mt7992_emmc/hw_nat$ git diff hwnat_ioctl.c > temp_patch.patch raco@ubuntu_2204:~/data/mtk_code/T830/T830/openwrt/build_di...

PG主节点挂了，为什么备节点不会自动升主

git 拉取指定commit id的代码

WordPress自定义分享插件可以分享到微信朋友圈的那种我要自己写插件

如何在一个docker中运行多个程序

golang ipv6 地址转整数

Vue.prototype.zipMedia = async function(media) { const zip = new JSZip(); console.log("media.length: ", media.length); console.log("zipMedia_media: ", media); if (!media || media.length === 0) { return null; // 返回 null 表示没...

golang 布隆过滤器

golang + rdp 协议+tls，实现远程桌面服务端和客户端

git 拉取指定commit id的代码

golang为什么将method写在类外?

git命令提交部分文件的修改

//校验搜索条件一个必填 const trimLeft = function trimLeft(s) { return s.replace(/(^\s*)/g, ''); }; const isEmpty = function isEmpty(value) { return value === undefined || value === null || trimLeft(value) === ''; }; const checkRequired = (data) => {

golang 打印变量类型

Qt添加样式让QLabel有边框

PS C:\Users\Muza\Desktop\Work\JAVA\HTHD\Work_Dev_3.0.3> git merge --abort fatal: There is no merge to abort (MERGE_HEAD missing). 这是为什么

Golang 操作Windows注册表教程

docker打包Django项目是无法安装mysqlclient怎么办

mongodb 时区配置

docker clash-for-linux 配置方法

怎么查看当前运行的k8s版本

联系我们

filebeat output.kafka 仅发送选定字段

相关推荐

git 拉取指定commit id的代码

WordPress自定义分享插件 可以分享到微信朋友圈的那种 我要自己写插件

如何在一个docker中运行多个程序

golang ipv6 地址转整数

Vue.prototype.zipMedia = async function(media) { const zip = new JSZip(); console.log("media.length: ", media.length); console.log("zipMedia_media: ", media); if (!media || media.length === 0) { return null; // 返回 null 表示没...

golang 布隆过滤器

golang + rdp 协议+tls，实现远程桌面服务端和客户端

git 拉取指定commit id的代码

golang为什么将method写在类外?

联系我们

登录

注册

WordPress自定义分享插件可以分享到微信朋友圈的那种我要自己写插件