[JSON を Kafka Topic に書き込み]出力コネクタは、一般的な JSON として適合され、書式設定されたイベント データを Apache Kafka Topic に書き込むために使用されます。 Apache Kafka の基本操作の詳細については、「Apache Kafka の概要」をご参照ください。
使用上の注意
[JSON を Kafka Topic に書き込み]出力コネクタを使用する際には、以下の点に注意してください。
- この出力コネクタを使用して、一般的な JSON として適合され、書式設定されたデータを Kafka Topic に書き込みます。 この出力コネクタは、Kafka への Producer です。
- この出力コネクタは、JSON アウトバウンド アダプターと Kafka アウトバウンド トランスポートを組み合わせます。
- 汎用 JSON レコードには、ジオメトリを表すデータを含める必要はありません。 非空間データを Kafka Topic に書き込むことはできません。
- アダプターは、単一の JSON レコードと、配列に整理された JSON レコードの両方を管理します。
- Kafka インバウンド トランスポートは、Kafka クラスターまたは Broker で認証するために、TLS 1.2 および SASL セキュリティ プロトコルをサポートしています。
パラメーター
[JSON を Kafka Topic に書き込み]出力コネクタのパラメーターを次に示します。
| パラメーター | 説明 |
|---|---|
名前 | GeoEvent Manager で参照用として使用される入力コネクタの記述名。 |
カスタム Kafka プロパティでオーバーライド | デフォルトの GeoEvent Server Kafka クライアント プロパティをオーバーライドするかどうかを指定します。 デフォルトは [いいえ] です。
|
Kafka Bootstrap Servers (条件) | Kafka クラスターへの初期接続を確立するために使用される hostname:port ペアのリスト。 Hostname:port ペアは、カンマ区切りである必要があります (例: broker0.example.com:9092,broker1.example.com:9092,broker2.example.com:9092)。 |
Kafka プロパティ ファイルの登録済みフォルダー (条件) | Kafka .properties ファイルを含む GeoEvent Server に登録されたフォルダー。 Kafka .properties ファイルは、[カスタム Kafka プロパティでオーバーライド] が [はい] に設定されている場合にカスタム Kafka プロパティを定義します。 GeoEvent Server に登録されたフォルダーが、Kafka .properties ファイルが配置された場所への絶対パスであることを確認してください。 |
Kafka プロパティ ファイル名 (条件) | クライアント構成のカスタム Kafka プロパティを含む Kafka .properties ファイルの名前。 ファイルの名前は拡張子 .properties なしで指定する必要があります。
|
トピック名 | データの公開先となる Kafka Topic の名前。
注意:Kafka アウトバウンド トランスポートは、複数の Topic へのデータの公開をサポートしていません。 |
Exactly Once Delivery の有効化 | トピックに書き込む際に正確に 1 回のセマンティクスが適用されるかどうかを指定します。 詳細については、「正確に 1 回のセマンティクス」をご参照ください。 デフォルトは [はい] です。
注意:[Exactly Once Delivery の有効化] パラメーターを続ける前に、Kafka クラスターが正確に 1 回のセマンティクスをサポートしていることを確認してください。 正確に 1 回のセマンティクスを有効にすると、パフォーマンスが代償となります。 詳細については、認証メッセージに関連する「Producer Configs」をご参照ください。 |
フォーマット済 JSON | フィーチャ JSON 文字列を、空白インデントと改行のフォーマットで整形するかどうかを指定します。 この JSON は PJSON と呼ばれることもあり、通常は、テキスト エディターでコンテンツを確認するシステム ファイルに書き込む場合にのみ適しています。 デフォルトは [いいえ] です。
|
認証が必要 | Kafka クラスターまたは Kafka Broker への接続に認証が必要かどうかを指定します。 デフォルトは [いいえ] です。
|
認証方法 (条件) | Kafka クラスターのセキュリティ保護に使用されるセキュリティ プロトコルを指定します。 利用できるセキュリティ プロトコルは TLS 1.2 および SASL です。
注意:Kerberos を使用する場合、ArcGIS GeoEvent Server を実行しているオペレーティング システムのユーザー アカウントに、Kerberos セットアップ/構成内のキータブ ファイルへの読み取りアクセス権があることを確認してください。 このパラメーターは、[認証が必要] が [はい] に設定されている場合に表示されます。 |
認証情報ファイルの登録済みフォルダー (条件) | Kafka クラスターの PKI ファイル (x509 証明書) を含む GeoEvent Server に登録されたフォルダー。 GeoEvent Server に登録されたフォルダーが、Kafka クラスターの証明書が配置された場所への絶対パスであることを確認してください。 |
認証情報の構成ファイル (条件) | Kafka クラスターの PKI ファイル (x509 証明書) の名前。 この証明書とそれに関連するプライベート キーは、拡張子 .p12 または .pfx を持つファイルで表される PKCS#12 形式で保存する必要があります。 ファイルの名前と拡張子を指定します。
注意:このパラメーターでは、証明書ファイル名と拡張子のみがサポートされます。 証明書への相対パスはこのパラメーターに指定しないでください。 [認証情報ファイルの登録済みフォルダー] パラメーターを使用して証明書ファイルへの絶対パスを登録します。 このパラメーターは、[認証が必要] が [はい] に設定されている場合に表示されます。 これは TLS 1.2 にのみ適用されます。 |
キーストアのパスワード (条件) | Kafka クラスターの PKI ファイル (x509 証明書) のパスワード。 これは証明書のプライベート キーとも呼ばれます。 |
SASL 認証タイプ (条件) | Kafka クラスターがサポートする SASL 認証メカニズムのタイプを指定します。 利用可能な SASL 認証タイプには、SASL GSSAPI (Kerberos) と SASL PLAIN が含まれます。
|
Kerberos プリンシパル (条件) | 特定ユーザーの Kerberos プリンシパル (例: GeoEventKafkaClient1@example.com)。 |
キー タブの使用 (条件) | キータブを Kerberos 設定で使用するかどうかを指定します。 デフォルトは [はい] です。
|
キーの保存 (条件) | キーを Kerberos 設定に保存するかどうかを指定します。 デフォルトは [はい] です。
|
ユーザー名 (条件) | Kafka クラスターでの認証に使用されるユーザー名を指定します。 クラウド プロバイダーによっては、接続文字列とも呼ばれます。 正しい構文については選択したクラウド プロバイダーのドキュメントをご参照ください。 |
パスワード (条件) | Kafka クラスターでの認証に使用されるパスワードを指定します。 正しい構文については選択したクラウド プロバイダーのドキュメントをご参照ください。 |
検討事項および制限事項
[JSON を Kafka Topic に書き込み]出力コネクタは、Kafka への Producer です。 Kafka への他の外部 Producer に必要であるのと同じ検討事項を、この出力コネクタに適用してください。