重要
このページの日本語コンテンツは古くなっている可能性があります。最新の英語版コンテンツをご覧になるには、こちらをクリックしてください。
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"
ちなみに
その他の例については、マネージド型コネクターの「タイムスタンプコンバーター」を参照してください。
プロパティ¶
| 名前 | 説明 | 型 | デフォルト | 指定可能な値 | 重要度 |
|---|---|---|---|---|---|
target.type |
変換後のタイムスタンプの表現: string、unix、Date、Time、または Timestamp | string | 高 | ||
field |
タイムスタンプを含むフィールド。値全体がタイムスタンプの場合は空白にします。 | string | "" | 高 | |
format |
java.text.SimpleDateFormat と互換性のある、タイムスタンプのフォーマット文字列。type=string の場合に、出力の生成に使用されます。または、入力が文字列の場合に、入力の解析に使用されます。詳細については、「SimpleDateFormat」を参照してください。 |
string | "" | 中 |
述語¶
"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter（Apache Kafka） と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。