Потоковая передача во внешние системы

Обзор

Возможна потоковая передача значений элементов данных и событий из Zabbix во внешние системы по HTTP (смотрите подробности протокола).

Для потоковой передачи подмножеств значений элементов данных или событий можно использовать фильтр тегов.

За потоковую передачу данных отвечают два типа процессов сервера Zabbix: менеджер коннекторов (connector manager) и рабочий процесс коннектора (connector worker). Внутренний элемент данных Zabbix zabbix[connector_queue] позволяет отслеживать количество значений, поставленных в очередь коннектора.

Настройка

Для настройки потоковой передачи данных во внешнюю систему выполните следующие действия:

1. Настройте удаленную систему для получения данных от Zabbix. Для этого доступны следующие инструменты:

• Пример простого получателя, который записывает полученную информацию в файлы events.ndjson и history.ndjson.
• Kafka connector for Zabbix server - легковесный сервер, написанный на Go и предназначенный для передачи значений элементов данных и событий с сервера Zabbix брокеру Kafka.

2. Укажите необходимое количество рабочих процессов коннектора в Zabbix, изменив параметр StartConnectors в zabbix_server.conf. Количество рабочих процессов коннектора должно соответствовать количеству настроенных коннекторов в веб-интерфейсе Zabbix (или превышать его, если количество параллельных сеансов больше 1). Затем перезапустите сервер Zabbix.

3. Настройте новый коннектор в веб-интерфейсе Zabbix (Администрирование > Общие > Коннекторы) и перезагрузите кэш сервера с помощью команды zabbix_server -R config_cache_reload.

Обязательные поля отмечены звездочкой.

Если коннектор Kafka настроен с разделенным запятыми списком адресов начальных брокеров (например, Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093), клиент Kafka подключается к брокеру или брокерам, которые ответили первыми, и использует метаданные их кластера. Если список содержит адреса из разных кластеров Kafka, будет использоваться только кластер, ответивший быстрее всего, а остальные адреса будут записаны в журнал как недоступные; в результате могут появиться предупреждения при запуске, подобные следующему, даже если коннектор подключен:

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-адреса могут разрешаться в loopback-адреса (например, 127.0.0.1/localhost) или нормализоваться клиентом, из-за чего такие предупреждения могут вводить в заблуждение. Чтобы уменьшить вероятность путаницы, убедитесь, что все адреса Kafka.URL принадлежат одному кластеру Kafka, проверьте разрешение DNS с узла сети коннектора и параметры advertised.listeners брокеров, а также отдавайте предпочтение адресам, которые разрешаются в рекламируемый адрес брокера.

Протокол

Обмен между сервером и приемником осуществляется по HTTP с использованием REST API, NDJSON, "Content-Type: application/x-ndjson".

Подробнее см. Протокол экспорта 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"}