2 流式传输到外部系统

概述

可以通过 HTTP 将监控项值和事件从 Zabbix 流式传输到外部系统（请参阅协议详细信息）。

可以使用标签过滤器来流式传输部分监控项值或事件。

两种 Zabbix 服务器进程类型负责数据流式传输：connector manager 和 connector worker。 Zabbix 内部监控项 zabbix[connector_queue] 可用于监控连接器队列中排队的值数量。

配置

需要执行以下步骤，将数据流式传输到外部系统：

1. 设置远程系统，以接收来自 Zabbix 的数据。 为此，可以使用以下工具：

• 一个简单的 receiver 示例，可将接收到的信息记录在 events.ndjson 和 history.ndjson 文件中。
• Zabbix 服务器的 Kafka connector - 一个使用 Go 编写的轻量级服务器，用于将 Zabbix 服务器中的监控项值和事件转发到 Kafka broker。

2. 在 Zabbix 中调整 zabbix_server.conf 文件中的 StartConnectors 参数，设置所需的 connector worker 数量。 connector worker 的数量应与 Zabbix 前端中配置的 connector 数量相匹配（如果并发会话数大于 1，则应大于或等于该数量）。 然后，重启 Zabbix 服务器。

3. 在 Zabbix 前端中配置新的 connector（管理 > 常规 > Connectors），并使用 zabbix_server -R config_cache_reload 命令重新加载服务器缓存。

必填字段以星号标记。

当 Kafka connector 配置为使用以逗号分隔的 bootstrap broker 地址列表时（例如 Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093），Kafka 客户端会连接到最先响应的 broker，并使用其集群元数据。 如果列表中包含来自不同 Kafka 集群的地址，则只会使用响应最快的集群，其他地址将记录为不可用；因此，即使 connector 已连接，也可能出现如下启动警告：

kafka cluster connected, but broker(s) "kafka1.example.com:9093, kafka2.example.com:9093" unavailable; will retry on message send if active brokers fail 

在某些环境中（专用网络、容器网络或非标准 DNS/hosts 配置），主机名或 IP 可能解析为回环地址（例如 127.0.0.1/localhost），或被客户端规范化，这可能导致此类警告产生误导。 为减少混淆，请确保所有 Kafka.URL 地址都属于同一个 Kafka 集群，验证 connector 主机上的 DNS 解析以及 broker 的 advertised.listeners，并优先使用可解析为 broker 广播地址的地址。

协议

服务器与接收器之间的通信通过使用 REST API 和 NDJSON（Newline-delimited JSON）格式的 HTTP 完成，内容类型为 "Content-Type: application/x-ndjson"。

有关更多详细信息，请参阅 Newline-delimited JSON 导出协议。

服务器请求

流式传输监控项值的示例：

POST /v1/history HTTP/1.1
Host: localhost:8080
Accept: */*
Accept-Encoding: deflate, gzip, br, zstd
Content-Length: 628
Content-Type: application/x-ndjson

{"host":{"host":"Zabbix server","name":"Zabbix server"},"groups":["Zabbix servers"],"item_tags":[{"tag":"foo","value":"test"}],"itemid":44457,"name":"foo","clock":1673454303,"ns":800155804,"value":0,"type":3}
{"host":{"host":"Zabbix server","name":"Zabbix server"},"groups":["Zabbix servers"],"item_tags":[{"tag":"foo","value":"test"}],"itemid":44457,"name":"foo","clock":1673454303,"ns":832290669,"value":1,"type":3}
{"host":{"host":"Zabbix server","name":"Zabbix server"},"groups":["Zabbix servers"],"item_tags":[{"tag":"bar","value":"test"}],"itemid":44458,"name":"bar","clock":1673454303,"ns":867770366,"value":123,"type":3}

流式传输事件的示例：

POST /v1/events HTTP/1.1
Host: localhost:8080
Accept: */*
Accept-Encoding: deflate, gzip, br, zstd
Content-Length: 333
Content-Type: application/x-ndjson

{"clock":1673454303,"ns":800155804,"value":1,"eventid":5,"name":"trigger for foo being 0","severity":0,"hosts":[{"host":"Zabbix server","name":"Zabbix server"}],"groups":["Zabbix servers"],"tags":[{"tag":"foo_trig","value":"test"},{"tag":"foo","value":"test"}]}
{"clock":1673454303,"ns":832290669,"value":0,"eventid":6,"p_eventid":5}

接收器响应

响应由 HTTP 响应状态码和 JSON 负载组成。
对于已成功处理的请求，HTTP 响应状态码必须为“200”、“201”、“202”、“203”或“204”；其他状态码表示请求失败。

成功示例：

HTTP/1.1 200 OK
Content-Type: application/json
X-Content-Type-Options: nosniff
Date: Tue, 21 Apr 2026 10:13:04 GMT
Content-Length: 23

{"response":"success"}

错误示例：

HTTP/1.1 422 Unprocessable Entity
Content-Type: application/json
X-Content-Type-Options: nosniff
Date: Tue, 21 Apr 2026 12:15:01 GMT
Content-Length: 55

{"error":"invalid character '{' after top-level value"}