在我的kafkastreams应用程序中,我有一个注册的本地商店(简单计数器),在 transform 方法
transform
在 punctuate 方法I基本上循环遍历Kv存储并将所有数据推送到输出主题(所以即使值没有更新)。
punctuate
一个想法是存储每个密钥的更新时间戳,并只转发自上次更新后的记录 标点符号 打电话。
标点符号
但我认为应该有一个更方便的解决方案。
如何使此项更具性能并仅转发更新的条目?
如马蒂亚斯的评论所述,目前不支持跟踪更新的记录。
更新值中的时间戳(或创建包含可修改时间戳的“值包装器”对象)并检查自上次标点调用以来是否已发生更新的方法是有效的。
-帐单
