複数のオフセットと範囲の指定によるApache Kafkaトピックからのメッセージの消費
複数のオフセットと範囲を指定することで、「Apache Kafkaアダプタ」を使用してApache Kafkaトピックからのメッセージを消費するように統合を構成できます。
次の統合は、このパターンの実装方法の一例です:
- 「SOAPアダプタ」または「RESTアダプタ」をトリガー接続としてアプリケーション統合を作成します。
- 「Apache Kafkaアダプタ」を次のように構成します:
- 複数のオフセットと範囲を指定して、Kafkaトピックからレコードを消費します。
- 使用するトピックとメッセージ構造を指定します。 たとえば、XML Schema (XSD)ドキュメントと、メッセージに使用するヘッダーを指定します。
- 「SOAPアダプタ」または「RESTアダプタ」と「Apache Kafkaアダプタ」の間の適切なソースとターゲットのマッピングを実行するようにマッパーを構成します。
- マッピングでパーティションとそのオフセット範囲をマップまたは指定します(たとえば、「パーティション」は
0に、「オフセット範囲」形式は6,10-11,16にできます)。