apache-kafka - 当来自 kafka 的消息被读取为 Ktable 时，当它被读取为 Kstreams 并转换为 Ktable 时？

Question

有人可以给我一个示例实例，我们应该从 kafka 读取数据作为 Ktable 以及我需要从 kafka 读取数据作为 Kstream 并将其转换为 Ktable 的实例吗？谢谢。

标签： apache-kafkaapache-kafka-streams

Answer 1

当您阅读某个主题时，您会将其作为流阅读。如果您需要它作为一个表，因为您只需要您可以使用的每个键的最新值.toTable()。这相当于读取表格。

如果您读取流，那么您可能会执行一个聚合，该聚合本质上会转换为 KTable。

假设您有一个主题具有以下内容

K1: 1
K1: 2
K2: 1

将其作为 KTable 阅读将为您提供：

K1: 2
K2: 1

如果您要阅读为 KStream 并执行 sum 聚合将导致以下 Ktable

K1:3
K2:1