目次

Search

  1. はじめに
  2. Workflow Manager
  3. ワークフローとワークレット
  4. セッション
  5. セッション設定オブジェクト
  6. タスク
  7. ソース
  8. ターゲット
  9. 接続オブジェクト
  10. 検証
  11. ワークフローのスケジュール設定と実行
  12. メールの発信
  13. Workflow Monitor
  14. Workflow Monitorの詳細
  15. セッションとワークフローのログ
  16. セッションプロパティリファレンス
  17. ワークフロープロパティリファレンス

ワークフローベーシックガイド

ワークフローベーシックガイド

PowerExchange for Kafka接続

PowerExchange for Kafka接続

Kafka接続の設定時に、PowerCenter統合サービスがKafkaクラスタへの接続に使用する接続属性を指定します。SSLプロパティを設定すると、SSLを介してKafka Brokerに接続できます。
次の表に、Kafka接続のプロパティを示します。
プロパティ
説明
Kafka Brokerリスト
KafkaメッセージシステムブローカーリストのIPアドレスとポートの組み合わせ。
IPアドレスとポートの組み合わせの形式は次のとおりです。
<IPアドレス>:<ポート>
カンマ区切りで、複数のIPアドレスとポートの組み合わせを入力できます。
再試行タイムアウト(秒)
統合サービスがデータを書き込むためにKafka Brokerへの再接続を試行する秒数。
指定した時間にソースまたはターゲットを利用できない場合、データの損失を防ぐためマッピングの実行を停止します。
デフォルトは180秒です。
Kafka Brokerのバージョン
Kafkaメッセージングブローカのバージョンとして
[Apache 0.10.1.1以上]
を選択します。
追加接続プロパティ
Kafkaブローカーに接続するための接続プロパティのカンマ区切りリスト。
SSL経由でKafkaブローカーに接続するには、次のプロパティを設定します。
  • security.protocol
  • ssl.truststore.location
  • ssl.truststore.password
ssl.client.auth
パラメータが
required
または
requested
になっている場合、次のプロパティを設定します。
  • ssl.keystore.location
  • ssl.keystore.password
  • ssl.key.password
例:
security.protocol=SSL,ssl.truststore.location=<client.truststore.jksファイルの完全パスと名前>,ssl.truststore.password=<クライアントトラストストアのパスワード>,ssl.keystore.location=<client.keystore.jksファイルの完全パスと名前>,ssl.keystore.password=<クライアントキーストアのパスワード>,ssl.key.password=<個々のキーのパスワード>
Kerberised Kafkaクラスタへの接続に必要な構成プロパティも指定できます。
以下のプロパティを指定します。
security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI
SSLモード
PowerCenter統合サービスがKafka Brokerとのセキュアな接続を確立するかどうかを指定します。次のいずれかのオプションを選択できます。
  • disabled。PowerCenter統合サービスはKafka Brokerとの暗号化されていない接続を確立します。
  • require。PowerCenter統合サービスはサーバーのIDを確認することなくKafka Brokerとの暗号化された接続を確立します。
  • one-way。PowerCenter統合サービスはトラストストアファイルおよびトラストストアパスワードを使用してKafka Brokerとの暗号化された接続を確立します。
  • two-way。PowerCenter統合サービスはトラストストアファイルおよびトラストストアパスワードを使用してKafka Brokerとの暗号化された接続を確立します。
SSLトラストストアファイルパス
SSLモードとして
one-way
または
two-way
を選択した場合にのみ適用されます。
トラストストアファイルの完全なパスおよびファイル名。トラストストアファイルには、KafkaクラスタがKafka Broker証明書に対して検証するSSL証明書が含まれます。
SSLトラストストアパスワード
SSLモードとして
one-way
または
two-way
を選択した場合にのみ適用されます。
トラストストアファイルのパスワード。
SSLキーストアファイルパス
SSLモードとして
two-way
を選択した場合にのみ適用されます。
Javaキーストアファイルの完全なパスと名前。キーストアファイルには、Kafka BrokerがKafkaクラスタ証明書に対して検証する証明書が含まれます。
SSLキーストアパスワード
SSLモードとして
two-way
を選択した場合にのみ適用されます。
キーストアファイルのパスワード。
追加セキュリティプロパティ
PowerExchange for Kafkaには適用されません。