TimestampConverter

ここでは、Apache Kafka® SMT org.apache.kafka.connect.transforms.TimestampConverter の使用方法を説明します。

説明

Unix エポック、文字列、Connect の Date 型および Timestamp 型など、タイムスタンプのフォーマットを別のフォーマットに変換します。個々のフィールドまたは値全体に適用できます。

レコードキー用(org.apache.kafka.connect.transforms.TimestampConverter$Key)または値用(org.apache.kafka.connect.transforms.TimestampConverter$Value)の固有の変換タイプを使用します。

注釈

TimestampConverter SMT は、一度に 1 つのフィールドでのみ機能します。

サンプル

この構成スニペットは、TimestampConverter を使用して、Unix エポック(int64 値の形式)をフォーマットされた日付文字列に変換する方法を示しています。

"transforms": "TimestampConverter",
"transforms.TimestampConverter.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value",
"transforms.TimestampConverter.format": "yyyy-MM-dd",
"transforms.TimestampConverter.target.type": "string"

変換前: 1556204536000

変換後: "2014-04-25"

ちなみに

その他の例については、マネージド型コネクターの Timestamp Converter を参照してください。

特徴

Name 説明 デフォルト 指定可能な値 重要度
target.type 変換後のタイムスタンプの表現: string、unix、Date、Time、または Timestamp string    
field タイムスタンプを含むフィールド。値全体がタイムスタンプの場合は空白にします。 string ""  
format java.text.SimpleDateFormat と互換性のある、タイムスタンプのフォーマット文字列。type=string の場合に、出力の生成に使用されます。または、入力が文字列の場合に、入力の解析に使用されます。詳細については、「SimpleDateFormat」を参照してください。 string ""  

述語

"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter(Apache Kafka) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。