通过 Kafka 连接转换插入时间戳

Question

是否有 Kafka Connect 转换，将时间戳作为字段插入？

之前：

{
  "first": "second"
}

之后：

{
  "first": "second",
  "foo": 1589889270
}

Answer 1

是的，InsertField 单个消息转换会执行此操作

…
  'transforms' = 'ExtractTimestamp',
  'transforms.ExtractTimestamp.type'= 'org.apache.kafka.connect.transforms.InsertField$Value',
  'transforms.ExtractTimestamp.timestamp.field' = 'foo'

通过 Kafka 连接转换插入时间戳

Insert timestamp via Kafka Connect Transformation

apache-kafka-connect