Elastic Agent 输入插件

此插件除了堆内存外，还使用“堆外”直接内存。默认情况下，JVM 的堆外直接内存限制与堆大小相同。例如，设置 -Xmx10G 而不设置直接内存限制将为堆分配 10GB，并为直接内存额外分配 10GB，总共分配 20GB。您可以使用 Logstash JVM 设置中的 -XX:MaxDirectMemorySize 设置直接内存量。考虑将直接内存设置为堆大小的一半。将直接内存设置得太低会降低摄取性能。

使用 Elastic Agent 在 hostname 字段中提供的值确定是否向事件添加 host 字段的标志。

要使用的密码套件列表，按优先级列出。

在 X 秒不活动后关闭空闲客户端。

有关详细信息，请参阅ECS 映射。

示例

此配置禁用所有丰富功能

input {
  beats {
    port => 5044
    enrich => none
  }
}

或者，显式启用仅 source_metadata 和 ssl_peer_metadata（禁用所有其他丰富功能）

input {
  beats {
    port => 5044
    enrich => [source_metadata, ssl_peer_metadata]
  }
}

当设置为 0 时，实际默认值为 available_processors * 2

这是一个专家级设置，通常不需要设置。Elastic Agent 插件是基于非阻塞机制实现的，需要一些事件循环和执行器线程。事件循环线程负责与客户端通信（接受传入的连接、入队/出队任务和响应），而执行器线程处理任务。此配置旨在限制或增加为事件循环创建的线程数。如果需要设置执行器线程数，请参阅 executor_threads 配置。

用于处理传入的 Elastic Agent 请求的线程数。默认情况下，Elastic Agent 输入会创建与 CPU 核心数相等的线程数。这些线程处理传入的连接、从已建立的套接字读取数据以及执行与网络连接管理相关的大部分任务。解析 Lumberjack 协议被卸载到一个专用的线程池。

通常情况下，您不需要修改此设置。如果您发送非常大的事件并观察到“OutOfDirectMemory”异常，则可能需要将此数字减少到 CPU 核心数的一半或 1/4。此更改会减少将成批数据解压缩到直接内存中的线程数。但是，这只是一种缓解措施，因为正确的解决方案可能需要调整您的 Logstash 部署，方法是增加 Logstash 节点的数量或增加 JVM 的直接内存。

要监听的 IP 地址。

要监听的端口。

事件默认以纯文本形式发送。您可以通过将 ssl 设置为 true 并配置 ssl_certificate 和 ssl_key 选项来启用加密。

要使用的 SSL 证书。

根据这些授权机构验证客户端证书。您可以定义多个文件或路径。所有证书都将被读取并添加到信任存储中。您需要将 ssl_client_authentication 配置为 optional 或 required 才能启用验证。

要使用的密码套件列表，按优先级列出。此默认列表适用于 OpenJDK 11.0.14 及更高版本。对于较旧的 JDK 版本，默认列表仅包含该版本支持的套件。例如，较旧的版本不支持 ChaCha20 系列密码。

控制服务器在请求客户端连接证书方面的行为：required 强制客户端出示证书，而 optional 请求客户端证书，但客户端不是必须出示证书。默认为 none，禁用客户端身份验证。

启用相互 TLS 时（required 或 optional），客户端出示的证书必须由受信任的 ssl_certificate_authorities (CA) 签名。请注意，服务器不会验证客户端证书的 CN（通用名称）或 SAN（主题备用名称）。

事件默认以纯文本形式发送。您可以通过将 ssl_enabled 设置为 true 并配置 ssl_certificate 和 ssl_key 选项来启用加密。

不完整的 ssl 握手超时的时间（以毫秒为单位）

要使用的 SSL 密钥。此密钥必须采用 PKCS8 格式和 PEM 编码。您可以使用 openssl pkcs8 命令完成转换。例如，将 PEM 编码的 PKCS1 私钥转换为 PEM 编码的非加密 PKCS8 密钥的命令是

openssl pkcs8 -inform PEM -in path/to/logstash.key -topk8 -nocrypt -outform PEM -out path/to/logstash.pkcs8.key

要使用的 SSL 密钥密码。

启用将客户端证书信息存储在事件的元数据中。

仅当将 ssl_client_authentication 设置为 optional 或 required 时，此选项才有效。

建立到 HTTP 端点的连接时要使用的允许的 SSL/TLS 版本列表。

对于 Java 8，仅从 8u262 (AdoptOpenJDK) 开始支持 'TLSv1.3'，但要求您在 Logstash 中设置 LS_JAVA_OPTS="-Djdk.tls.client.protocols=TLSv1.3" 系统属性。

默认情况下，服务器不执行任何客户端验证。如果配置了 ssl_certificate_authorities，并且此选项没有提供值或提供 none 值，则默认为 force_peer 而不是 none。

peer 将使服务器要求客户端提供证书。如果客户端提供证书，则会对其进行验证。

force_peer 将使服务器要求客户端提供证书。如果客户端不提供证书，则会关闭连接。

启用相互 TLS 时（peer 或 force_peer），客户端出示的证书必须由受信任的 ssl_certificate_authorities (CA) 签名。请注意，服务器不会验证客户端证书的 CN（通用名称）或 SAN（主题备用名称）。

加密连接允许的最大 TLS 版本。该值必须是以下之一：1.1 表示 TLS 1.1，1.2 表示 TLS 1.2，1.3 表示 TLSv1.3

加密连接允许的最小 TLS 版本。该值必须是以下之一：1.1 表示 TLS 1.1，1.2 表示 TLS 1.2，1.3 表示 TLS 1.3

向事件添加字段

用于输入数据的编解码器。输入编解码器是一种方便的方法，可以在数据进入输入之前对其进行解码，而无需在 Logstash 管道中使用单独的过滤器。

禁用或启用此特定插件实例的指标日志记录。默认情况下，我们会记录所有可以记录的指标，但您可以禁用特定插件的指标收集。

向插件配置添加唯一的 ID。如果未指定 ID，Logstash 将生成一个。强烈建议在配置中设置此 ID。当您有两个或多个相同类型的插件时，这尤其有用，例如，如果您有 2 个 elastic_agent 输入。在这种情况下添加命名 ID 将有助于在使用监控 API 时监控 Logstash。

input {
  elastic_agent {
    id => "my_plugin_id"
  }
}

向您的事件添加任意数量的标签。

这有助于稍后进行处理。

为此输入处理的所有事件添加一个 type 字段。

类型主要用于过滤器激活。

该类型作为事件本身的一部分存储，因此您也可以使用该类型在 Kibana 中进行搜索。

如果您尝试在已经具有类型的事件上设置类型（例如，当您将事件从托运人发送到索引器时），则新的输入不会覆盖现有类型。在托运人处设置的类型会一直伴随该事件，即使发送到另一个 Logstash 服务器也是如此。