2 Strumieniowanie do systemów zewnętrznych

Przegląd

Możliwe jest strumieniowanie wartości pozycji i zdarzeń z Zabbix do zewnętrznych systemów przez HTTP (zobacz szczegóły protokołu).

Filtr tagów może być używany do strumieniowania podzbiorów wartości pozycji lub zdarzeń.

Za strumieniowanie danych odpowiadają dwa typy procesów serwera Zabbix: connector manager i connector worker. Wewnętrzna pozycja Zabbix zabbix[connector_queue] umożliwia monitorowanie liczby wartości umieszczonych w kolejce connector.

Konfiguracja

Aby skonfigurować strumieniowanie danych do systemu zewnętrznego, należy wykonać następujące czynności:

1. Skonfiguruj system zdalny do odbierania danych z Zabbix. W tym celu dostępne są następujące narzędzia:

• Przykład prostego odbiornika, który zapisuje odebrane informacje w plikach events.ndjson i history.ndjson.
• Kafka connector for Zabbix server - lekki serwer napisany w języku Go, przeznaczony do przekazywania wartości pozycji i zdarzeń z serwera Zabbix do brokera Kafka.

2. Ustaw wymaganą liczbę procesów roboczych connectora w Zabbix, dostosowując parametr StartConnectors w pliku zabbix_server.conf. Liczba procesów roboczych connectora powinna odpowiadać skonfigurowanej liczbie connectorów w frontend Zabbix (lub ją przekraczać, jeśli liczba jednoczesnych sesji jest większa niż 1). Następnie uruchom ponownie serwer Zabbix.

3. Skonfiguruj nowy connector w frontend Zabbix (Administration > General > Connectors) i przeładuj pamięć podręczną serwera za pomocą polecenia zabbix_server -R config_cache_reload.

Pola wymagane są oznaczone gwiazdką.

Jeśli connector Kafka zostanie skonfigurowany z rozdzielaną przecinkami listą adresów brokerów początkowych (na przykład Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093), klient Kafka połączy się z brokerem lub brokerami, które odpowiedzą jako pierwsze, i użyje metadanych ich klastra. Jeśli lista zawiera adresy z różnych klastrów Kafka, używany będzie tylko klaster odpowiadający najszybciej, a pozostałe adresy zostaną zapisane w dzienniku jako niedostępne; w rezultacie mogą pojawić się ostrzeżenia podczas uruchamiania, takie jak poniższe, nawet jeśli connector jest połączony:

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

W niektórych środowiskach (sieciach prywatnych, sieciach kontenerowych lub konfiguracjach niestandardowego DNS/hosts) nazwy hostów lub adresy IP mogą być rozwiązywane do adresów interfejsu loopback (na przykład 127.0.0.1/localhost) albo normalizowane przez klienta, co może powodować, że takie ostrzeżenia będą mylące. Aby ograniczyć niejasności, upewnij się, że wszystkie adresy Kafka.URL należą do tego samego klastra Kafka, sprawdź rozwiązywanie DNS z hosta connectora oraz wartości advertised.listeners brokerów i preferuj adresy rozwiązywane do adresu rozgłaszanego przez brokera.

Protokół

Komunikacja między serwerem a odbiorcą odbywa się przez HTTP z użyciem REST API, NDJSON, „Content-Type: application/x-ndjson”.

Więcej informacji można znaleźć w protokole eksportu JSON rozdzielanego znakami nowej linii.

Żądanie serwera

Przykład strumieniowania wartości pozycji:

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}

Przykład strumieniowania zdarzeń:

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}

Odpowiedź odbiorcy

Odpowiedź składa się z kodu statusu odpowiedzi HTTP oraz ładunku JSON. Kod statusu odpowiedzi HTTP musi mieć wartość "200", "201", "202", "203" lub "204" dla żądań, które zostały obsłużone pomyślnie, inny dla żądań zakończonych niepowodzeniem.

Przykład powodzenia:

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"}

Przykład z błędami:

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"}