使用 Stream DSL 在 Kafka Streams 中指定每个流/表时间戳提取器

Question

我想使用 Kafka Streams 加入两个不同的主题。这两个主题的数据格式不同，所以我想使用不同的时间戳提取器。我看到这个功能有一个合并的 pullrequest (KAFKA-4144)，但我 only find it 是处理器 API。

Stream API 是否存在此功能？

Answer 1

StreamsBuilder#stream(...) 的重载采用 Consumed 参数，允许您指定所有可选属性，例如时间戳提取器。

https://docs.confluent.io/current/streams/javadocs/org/apache/kafka/streams/Consumed.html

一般来说，您可以在升级指南中找到 API 更改说明：

• https://docs.confluent.io/current/streams/upgrade-guide.html#api-changes
• https://kafka.apache.org/10/documentation/streams/upgrade-guide#streams_api_changes_100