2 外部システムへのストリーミング

概要

Zabbixから外部システムへ、HTTP経由でアイテムの値やイベントをストリーミングできます（プロトコルの詳細を参照）。

タグフィルターを使用すると、アイテムの値やイベントのサブセットをストリーミングできます。

データストリーミングを担当するZabbixサーバーのプロセスタイプは、connector managerとconnector workerの2つです。 Zabbix内部アイテムzabbix[connector_queue]を使用すると、コネクターキューに登録された値の数を監視できます。

設定

外部システムへのデータストリーミングを設定するには、次の手順が必要です。

1. Zabbixからデータを受信するリモートシステムを用意します。 この目的のために、次のツールを利用できます。

• 受信した情報をevents.ndjsonおよびhistory.ndjsonファイルに記録する、シンプルなreceiverの例。
• Zabbixサーバー用Kafkaコネクター - ZabbixサーバーからKafkaブローカーへアイテムの値とイベントを転送するよう設計された、Goで記述された軽量サーバー。

2. zabbix_server.confのStartConnectorsパラメータを調整して、Zabbixで必要な数のコネクターワーカーを設定します。 コネクターワーカーの数は、ZabbixのWebインターフェースで設定したコネクター数と一致させる必要があります（同時セッション数が1より多い場合は、それ以上にします）。 その後、Zabbixサーバーを再起動します。

3. ZabbixのWebインターフェース（管理 > 一般設定 > コネクター）で新しいコネクターを設定し、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アドレスがループバックアドレス（例：127.0.0.1/localhost）に解決されたり、クライアントによって正規化されたりすることがあります。そのため、このような警告が誤解を招く場合があります。 混乱を避けるには、すべてのKafka.URLアドレスが同じKafkaクラスターに属していることを確認し、コネクターのホストからのDNS解決とブローカーのadvertised.listenersを確認してください。また、ブローカーのadvertisedアドレスに解決されるアドレスを使用することを推奨します。

プロトコル

サーバーとレシーバー間の通信は、REST API、NDJSON、"Content-Type: application/x-ndjson" を使用してHTTP経由で行われます。

詳細については、改行区切り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"}