クラス DefaultDebeziumHeaderMapper

java.lang.ObjectSE
org.springframework.integration.debezium.support.DefaultDebeziumHeaderMapper
実装されたすべてのインターフェース:
HeaderMapper<ListSE<io.debezium.engine.Header<ObjectSE>>>
public class DefaultDebeziumHeaderMapper extends ObjectSE implements HeaderMapper<ListSE<io.debezium.engine.Header<ObjectSE>>>
Debezium ChangeEvent.headers() を MessageHeaders に変換する方法を指定します。
導入:
6.2
作成者:
Christian Tzolov, Artem Bilan

  • コンストラクターの詳細

    • DefaultDebeziumHeaderMapper

      public DefaultDebeziumHeaderMapper()

  • メソッドの詳細

    • setHeaderNamesToMap

      public void setHeaderNamesToMap(StringSE... headerNames)
      送信メッセージヘッダーにマップされる Debezium の変更イベントヘッダーの名前のコンマ区切りリスト。Debezium 新規レコード状態抽出の 'add.headers' プロパティは、生成された ChangeEvent ヘッダーに設定されるメタデータを構成するために使用されます。'setHeaderNamesToMap' で使用される 'headerNames' の前に、'add.headers.prefix' debezium プロパティで構成されたプレフィックスを付ける必要があることに注意してください。後でデフォルトは '__' になります。たとえば、'add.headers=op,name' および 'add.headers.prefix=__' の場合、headerNames == "__op" , "__name" を使用する必要があります。
      パラメーター:
      headerNames - このリストの値は、ヘッダー名と照合する単純なパターンにすることができます。
      関連事項:

    • toHeaders

      public MessageHeaders toHeaders(ListSE<io.debezium.engine.Header<ObjectSE>> debeziumHeaders)
      次で指定:
      インターフェース HeaderMapper<ListSE<io.debezium.engine.Header<ObjectSE>>> の toHeaders 

    • fromHeaders

      public void fromHeaders(MessageHeaders headers, ListSE<io.debezium.engine.Header<ObjectSE>> target)
      次で指定:
      インターフェース HeaderMapper<ListSE<io.debezium.engine.Header<ObjectSE>>> の fromHeaders