在我的kafkastreams应用程序中，我有一个注册的本地商店（简单计数器），它在 transform 方法。
在 punctuate 方法i基本上循环kv存储并将所有数据推送到输出主题（即使值没有更新）。
一个想法是存储每个键的更新时间戳，并只转发自上次更新以来的记录 punctuate 打电话。
但我认为应该有一个更方便的解决办法。
如何使这个更有效，只转发更新的条目？
在我的kafkastreams应用程序中，我有一个注册的本地商店（简单计数器），它在 transform 方法。
在 punctuate 方法i基本上循环kv存储并将所有数据推送到输出主题（即使值没有更新）。
一个想法是存储每个键的更新时间戳，并只转发自上次更新以来的记录 punctuate 打电话。
但我认为应该有一个更方便的解决办法。
如何使这个更有效，只转发更新的条目？
1条答案
按热度按时间cygmwpex1#
如matthias的评论所示，目前不支持跟踪更新的记录。
更新值中的时间戳（或创建包含可以修改的时间戳的“值 Package 器”对象）并检查自上次标点调用以来是否发生了更新的方法是有效的方法。
-比尔