代码之家 › 专栏 › 技术社区 › kellanburket

当一个密钥的实际值在更新之后保持不变时,卡夫卡表的变更符是否向其流发出新事件?

apache-kafka-streams apache-kafka

kellanburket · 技术社区 · 6 年前

假设我有一个记录位置数据的ktable(例如: {'Susan': 'Paris'} )并使用 toStream 那张桌子的方法。

我知道如果要更新表的话 Susan (例如: Berlin )那么changelog流将发出一个新事件 {'Susan': 'Berlin'} . 但如果更新后的值与上次相同怎么办?--例如,在聚合操作期间,我们设置 苏珊 到 柏林 第二次。

变更日志是否发出第二个 {'susan':'berlin'} 事件或新的事件只在新的和新的值之间存在差异时才添加到变更日志流中吗?

1 回复 | 直到 6 年前

Matthias J. Sax 6 年前

总是发出更新。没有检查来比较旧值和新值,假设新值与旧值不同,因此每次都会发出。

推荐文章

Stella · Kafka流处理期间处理数据时出现异常

6 年前

Stella · kafka流中的处理器节点

6 年前

mukesh210 · 卡夫卡流:Lib Rocks数据库上的UnsatifiedLinkError

6 年前

el323 · Kafka流:通过Json日志中的键进行分组

6 年前

Suchita · 如何使用Avro反序列化器和Avro序列化器为KafkaStreams编写Junit测试用例

6 年前

Cemo · 如何获得有关GlobalKTable状态存储更新的通知?

7 年前

px5x2 · Kafka将GlobalKTable同步流传输到应用程序

7 年前

Dth · 加工机为Kafka流中的单个任务多次调用init()

7 年前

nattyddubbs · Kafka Streams多实例设计含义

7 年前

dvlcis · 如何使用卡夫卡流窗口为烛台图生成创建一条记录

7 年前