Apache Kafka
Apache Kafkaは、オープンソースの分散イベントストリーミングプラットフォームです。 多くの業界や組織で、支払いの処理やその他の金融取引のリアルタイム実行、顧客とのやり取りや注文の収集と即時対応、データプラットフォーム、マイクロサービスなどの基盤として使用されています。
Workato Apache Kafkaコネクターを使用すると、ローカルまたはWebのKafkaクラスターインスタンスにリンクし、次のことができます。
- 新規メッセージトリガーまたは新規メッセージトリガー（バッチ）を使用してメッセージをコンシュームします。
- メッセージのパブリッシュアクションまたはメッセージのパブリッシュアクション（バッチ）を使用してメッセージを送信します。
WorkatoでApache Kafkaに接続する方法
クラウドプロファイルOPAを使用してWorkatoでApache Kafkaへのコネクションを確立するには、次の手順を実行します。
ローカルプロファイルのセットアップ
このガイドの手順では、Cloud Profileを使用してApache Kafkaコネクションを設定します。 config.ymlファイルを使用してコネクションを設定するには、Apache Kafka Profileガイドを参照してください。
Workatoが接続しているApache Kafkaインスタンスを識別するコネクション名を入力します。
コネクションを作成
ロケーションドロップダウンメニューを使用して、コネクションを保存するプロジェクトを選択します。
オンプレミスグループドロップダウンメニューを使用して、クラウドプロファイルを使用するオンプレミスグループを選択します。
kafkaまたはkafka+sslプロトコルを使用するサーバーURLを入力します。
一般的な操作のタイムアウトをミリ秒単位で指定します。
SSL/TLSを使用してKafkaに接続するには、次の値を.pem形式で入力します。
X509サーバー証明書およびSSLクライアント証明書を入力します。
RSASSLクライアントキーを入力します。
任意です。 RSASSLクライアントキーパスワードを入力します。 パスワードで保護された秘密鍵をインライン化しないでください。
任意です。 Kafkaコネクションの追加プロパティセクションを展開し、パラメーターを追加をクリックして追加プロパティを定義します。
追加プロパティの定義
任意のKafkaプロデューサーまたはコンシューマー設定プロパティを定義できます。 例：bootstrap.serversまたはbatch_size。
一部のプロパティは、オンプレミスエージェントによって上書きされるため使用できません。 保護されたプロパティには、次のものがあります。
| プロパティ名 | 詳細 |
|---|---|
| key.serializer | エージェントではStringSerializerのみがサポートされています。 |
| value.serializer | エージェントではStringSerializerのみがサポートされています。 |
| key.deserializer | エージェントではStringSerializerのみがサポートされています。 |
| value.deserializer | エージェントではStringSerializerのみがサポートされています。 |
| auto.offset.reset | レシピで定義されます。 |
| enable.auto.commit | 内部で定義されます。 |
Kafkaコネクターは、バイナリシリアル化形式であるApache Avroを使用します。 Avroは、JSONスキーマを使用して存在するフィールドとその型を定義します。 コネクターはデータをスキーマレジストリに保存します。 Kafkaコネクターには、スキーマレジストリのバージョン6.1.4以降が必要です。 例:
スキーマレジストリURLを使用したKafkaコネクション設定
接続をクリックします。
NO PROFILE FOUNDエラーのトラブルシューティング
No profile foundエラーが発生した場合は、オンプレミスコネクションの問題のトラブルシューティングガイドを参照してください。
Last updated: