我在正在进行的 springboot 项目中使用 Kafka 流，我想从输入主题中提取时间戳，如何做到这一点？

Question

每次kafka流订阅输入主题并将数据转储到输出主题时，现在我想要提取时间戳并转储到json对象的方法，该对象将被发送到输出主题

我尝试使用使用 .timestamp 的 kafka 消费者 inbuild 方法，它在 kafka 流中不起作用。

Answer 1

在 Kafka Streams 中，您可以使用 Processor API 来访问时间戳，例如

buidler.stream(...).process(...).to(...)'

在较新版本中，

Processor#process(Record)

方法可让您通过

Record#timestamp()

直接访问。

在旧版本中，您需要使用提供的

ProcessorContext#timestamp()

方法，您可以通过

Processor#init(ProcessorContext)

获得