Kafka Stream和Table以不同的时间间隔连接-Java 学习之路

我有一个非常典型的场景，我需要在时间t1从一个主题到另一个主题的KTable执行KStream之间的交叉连接 . 为了解释这一点，我想出了一个图表 . 请参考图片 . 我想了解Kafka Streams是否可行 . 我非常清楚交叉连接是可能的 . 但是，我想知道在不同的时间范围内是否可以进行连接 .

enter image description here

1 回答

2
不确定我是否正确理解了这个问题，但您可以通过提供自定义时间戳提取器来“转移”时间：
```
builder.table("topciName", Consumed.with(new MyTimestampExtractor()));

class MyTimestampExtractor implements TimestampExtractor { ... }
```
回复于 2024-05-09T19:19:54+08:00

Kafka Stream和Table以不同的时间间隔连接

1 回答

相关问题