Skip To Content

テキストを Kafka Topic に書き込み

[テキストを Kafka Topic に書き込み]出力コネクタは、イベント データを処理し、区切りテキストとしてフォーマットして Apache Kafka Topic に書き込むために使用されます。 Apache Kafka の基本操作の詳細については、「Apache Kafka の概要」をご参照ください。

使用上の注意

[テキストを Kafka Topic に書き込み]出力コネクタを使用する際には、以下の点に注意してください。

  • ポイントが与えられた場合、プロセッサは同じポイントを作成します。
  • 2 つの頂点を持つラインが与えられた場合、プロセッサは同じラインを作成します。
  • 単純な凸ポリゴンまたはエンベロープが与えられた場合、プロセッサは同じジオメトリを作成します。

  • この出力コネクタを使用して、データを処理し、区切りテキストとしてフォーマットして Kafka Topic に書き込みます。 この出力コネクタは、Kafka への Producer です。
  • この出力コネクタは、テキスト アウトバウンド アダプターと Kafka アウトバウンド トランスポートを組み合わせます。
  • イベント レコードを Kafka に書き込む前に区切りテキストとしてフォーマットするには、[メッセージの区切り記号]と[属性の区切り記号]が必要です。 メッセージの区切り記号は、データ レコードの末尾を表す文字です。デフォルトは \n (改行) です。 [属性の区切り記号]は、1 行のテキストで属性を区切るための記号を指定します。デフォルトは , (カンマ) です。 文字値または Unicode 値として指定された一般的な ASCII 文字を、メッセージまたは属性の区切り記号として使用できます。
  • Kafka インバウンド トランスポートは、Kafka クラスターまたは Broker で認証するために、TLS 1.2 および SASL セキュリティ プロトコルをサポートしています。

パラメーター

[テキストを Kafka Topic に書き込み]出力コネクタのパラメーターを次に示します。

パラメーター説明

名前

GeoEvent Manager で参照用として使用される入力コネクタの記述名。

カスタム Kafka プロパティでオーバーライド

デフォルトの GeoEvent Server Kafka クライアント プロパティをオーバーライドするかどうかを指定します。 デフォルトは [いいえ] です。

  • [はい] – トランスポートにより表示されるデフォルトの Kafka クライアント プロパティはオーバーライドされます。 有効な Kafka 構成が正しく書式設定された Kafka .properties ファイルを含む、GeoEvent Server に登録されたフォルダーを指定する必要があります。 サポートされている構成のリストと指定された .properties ファイルの推定される書式設定については、「Apache Kafka の構成」をご参照ください。
  • [いいえ] – トランスポートにより表示されるデフォルトの Kafka クライアント プロパティはオーバーライドされません。 [Kafka Bootstrap Servers][Consumer のグループ ID] を指定する必要があります。

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 プロパティ ファイルの名前が「sample.properties」の場合、このパラメーターを「sample」と指定します。

トピック名

データの公開先となる Kafka Topic の名前。

  • topic1

注意:

Kafka アウトバウンド トランスポートは、複数の Topic へのデータの公開をサポートしていません。

Exactly Once Delivery の有効化

トピックに書き込む際に正確に 1 回のセマンティクスが適用されるかどうかを指定します。 詳細については、「正確に 1 回のセマンティクス」をご参照ください。 デフォルトは [はい] です。

  • [はい]Kafka は正確に 1 回のセマンティクスを適用します。
  • [いいえ]Kafka は正確に 1 回のセマンティクスを適用しません。

注意:

[Exactly Once Delivery の有効化] パラメーターを続ける前に、Kafka クラスターが正確に 1 回のセマンティクスをサポートしていることを確認してください。 正確に 1 回のセマンティクスを有効にすると、パフォーマンスが代償となります。 詳細については、認証メッセージに関連する「Producer Configs」をご参照ください。

イベントの区切り記号

イベント データ レコードの末尾を表す文字リテラル。 区切り文字を指定するには、Unicode 値が使用されることがあります。 文字は引用符で囲んではなりません。 一般的なレコード末尾区切り文字は、改行 (\n) です。

フィールドの区切り記号

メッセージ内で属性値を区切るために使われるリテラル記号。 区切り文字を指定するには、Unicode 値が使用されることがあります。 文字は引用符で囲んではなりません。 一般的な属性区切り記号はカンマです。

出力日付形式

ファイルに書き込まれる日付/時間の値の形式を指定します。 使用可能な出力日付形式は、[ISO 8601 形式][カスタム形式] です。 デフォルトは [ISO 8601 形式] です。

  • [ISO 8601 形式] – 処理される日付/時間の値は、ISO 8601 形式 (yyyy-MM-dd'T'HH:mm:ss.SSSXXX) に準じて作成されます。
  • [カスタム形式] - 処理される日付/時間の値は、Java SimpleDateFormat クラス変換を使用し、カスタム形式に準じて作成されます。

カスタム日付形式

ファイルに書き込まれる、ユーザー指定形式の日付/時間。 ユーザー指定の日付形式は、Java SimpleDateFormat クラス変換を使用して作成する必要があります。 詳細については、「SimpleDateFormat」をご参照ください。

数値形式の言語

データ値から数値を書式設定する際、ロケール依存型の動作に使用されるロケール識別子 (ID)。 デフォルトは、GeoEvent Server がインストールされているコンピューターのロケールです。 詳細については、「Java Supported Locales」をご参照ください。

認証が必要

Kafka クラスターまたは Kafka Broker への接続に認証が必要かどうかを指定します。 デフォルトは [いいえ] です。

  • [はい]Kafka クラスターまたは Broker への接続に認証が必要です。
  • [いいえ]Kafka クラスターまたは Broker への接続に認証は不要です。

認証方法

(条件)

Kafka クラスターのセキュリティ保護に使用されるセキュリティ プロトコルを指定します。 利用できるセキュリティ プロトコルは TLS 1.2 および SASL です。

  • [TLS 1.2]Kafka クラスターが使用するセキュリティ プロトコルは TLS 1.2 です。 Kafka クラスターの PKI ファイル (x509 証明書) が、ArcGIS GeoEvent Server が構成されている ArcGIS Server のトラスト ストアにインポートされていることを確認してください。 証明書のインポートに関する具体的な手順については、「既存の CA 署名証明書での ArcGIS Server の構成」の「ArcGIS Server への証明書のインポート」セクションをご参照ください。
  • [SASL]Kafka クラスターによって使用されるセキュリティ プロトコルは、SASL です。 SASL、SSL、および Kerberos のみがサポートされています。

注意:

Kerberos を使用する場合、ArcGIS GeoEvent Server を実行しているオペレーティング システムのユーザー アカウントに、Kerberos セットアップ/構成内のキータブ ファイルへの読み取りアクセス権があることを確認してください。

このパラメーターは、[認証が必要][はい] に設定されている場合に表示されます。

認証情報ファイルの登録済みフォルダー

(条件)

Kafka クラスターの PKI ファイル (x509 証明書) を含む GeoEvent Server に登録されたフォルダー。 GeoEvent Server に登録されたフォルダーが、Kafka クラスターの証明書が配置された場所への絶対パスであることを確認してください。

認証情報の構成ファイル

(条件)

Kafka クラスターの PKI ファイル (x509 証明書) の名前。 この証明書とそれに関連するプライベート キーは、拡張子 .p12 または .pfx を持つファイルで表される PKCS#12 形式で保存する必要があります。 ファイルの名前と拡張子を指定します。

  • my_kafka_certificate.pfx
  • my_other_kafka_certificate.p12

注意:

このパラメーターでは、証明書ファイル名と拡張子のみがサポートされます。 証明書への相対パスはこのパラメーターに指定しないでください。 [認証情報ファイルの登録済みフォルダー] パラメーターを使用して証明書ファイルへの絶対パスを登録します。

このパラメーターは、[認証が必要][はい] に設定されている場合に表示されます。 これは TLS 1.2 にのみ適用されます。

キーストアのパスワード

(条件)

Kafka クラスターの PKI ファイル (x509 証明書) のパスワード。 これは証明書のプライベート キーとも呼ばれます。

SASL 認証タイプ

(条件)

Kafka クラスターがサポートする SASL 認証メカニズムのタイプを指定します。 利用可能な SASL 認証タイプには、SASL GSSAPI (Kerberos) と SASL PLAIN が含まれます。

  • [SASL/GSSAPI (Kerberos)]Kafka クラスターは SASL/GSSAPI Kerberos 認証を使用します。
  • [SASL/PLAIN]Kafka クラスターは SASL/PLAIN 認証を使用します。

Kerberos プリンシパル

(条件)

特定ユーザーの Kerberos プリンシパル (例: GeoEventKafkaClient1@example.com)。

キー タブの使用

(条件)

キータブを Kerberos 設定で使用するかどうかを指定します。 デフォルトは [はい] です。

  • [はい] – キータブは Kerberos 設定で使用されます。
  • [いいえ] – キータブは Kerberos 設定で使用されません。

キーの保存

(条件)

キーを Kerberos 設定に保存するかどうかを指定します。 デフォルトは [はい] です。

  • [はい] – キーは Kerberos 設定に保存されます。
  • [いいえ] – キーは Kerberos 設定に保存されません。

ユーザー名

(条件)

Kafka クラスターでの認証に使用されるユーザー名を指定します。 クラウド プロバイダーによっては、接続文字列とも呼ばれます。 正しい構文については選択したクラウド プロバイダーのドキュメントをご参照ください。

パスワード

(条件)

Kafka クラスターでの認証に使用されるパスワードを指定します。 正しい構文については選択したクラウド プロバイダーのドキュメントをご参照ください。

検討事項および制限事項

[テキストを Kafka Topic に書き込み]出力コネクタは、Kafka への Producer です。 Kafka への他の外部 Producer に必要であるのと同じ検討事項を、この出力コネクタに適用してください。