プロダクションから Kafka へのメッセージの送信
InterSystems IRIS は、相互運用プロダクションに Kafka 送信アダプタを使用するビジネス・オペレーションが含まれる場合に Kafka プロデューサになります。このアダプタにより、ビジネス・オペレーションは Kafka トピックにメッセージを送信できます。プロダクションを Kafka プロデューサとして使用する場合には、送信アダプタを利用する組み込みのビジネス・オペレーションを使用する、またはアダプタを使用する独自のビジネス・オペレーションを構築するという、2 つのオプションがあります。
アダプタの詳細
Kafka 送信アダプタは、クラス EnsLib.Kafka.OutboundAdapterOpens in a new tab です。これには以下の設定が含まれており、これらはすべて、管理ポータルにアダプタを使用するビジネス・オペレーションの設定として表示されます。
-
Servers は、Kafka クラスタ内のサーバを指定する、コンマ区切りの IP address:port エントリのリストを定義します。
-
ClientID は、プロデューサの Kafka クライアント ID を定義します。
-
Credentials は、Kafka クライアントのユーザ名とパスワードに対応するインターシステムズ認証情報を定義します。認証情報の作成の詳細は、"設定で使用する再利用可能項目の定義" を参照してください。
送信アダプタを使用するカスタムのビジネス・オペレーションの構築に関する一般情報は、"ビジネス・オペレーションの定義" を参照してください。
Kafka メッセージの送信
送信アダプタにより Kafka に送信されるメッセージのクラスは EnsLib.Kafka.MessageOpens in a new tab です。これには、以下のプロパティが含まれます。
-
topic は、プロデューサがメッセージを送信する Kafka トピックを定義します。
-
value (%String) は、Kafka メッセージのコンテンツを定義します。value が設定されている場合、binaryValue は設定しないでください。
-
binaryValue (任意の長さのバイナリ・ストリーム) は、メッセージの長さが %String の最大長を超える場合の、Kafka メッセージのコンテンツを定義します。binaryValue が設定されている場合、value は設定しないでください。
-
key は、Kafka メッセージのオプションのタグを定義します。
送信アダプタの SendMessage() メソッドは、唯一の引数として EnsLib.Kafka.MessageOpens in a new tab オブジェクトを取り、そのメッセージを Kafka サーバに送信します。例えば、カスタムのビジネス・オペレーションは、以下を含めることにより、アダプタのメソッドを呼び出すことができます。
Do ..Adapter.SendMessage(pRequest)
関連項目