【问题标题】：Kafka Streams : when will StateRestoreListener gets called?Kafka Streams：什么时候调用 StateRestoreListener？
【发布时间】：2021-01-18 04:29:23
【问题描述】：
我已将我的 kafka 流实例与 org.apache.kafka.streams.processor.StateRestoreListener 接口的实现相连接。我使用处理器 API 来定义我的流，它有一个状态存储。基本上流的工作是从输入主题中读取数据并将数据存储在状态存储中。
我想知道这个 StateRestoreListener 在什么情况下被调用。
当我第一次启动流时它会被调用吗？
当我启动另一个实例时它会被调用吗？
当我停止某个实例时它会被调用吗？
在每种情况下.. 调用哪些方法？
【问题讨论】：
标签：
apache-kafka
apache-kafka-streams
【解决方案1】：
当我第一次启动流时它会被调用吗？
不，因为当你第一次启动时，状态存储是空的，因此没有任何东西可以恢复。
当我启动另一个实例时它会被调用吗？
这会发生部分状态被迁移到新启动的实例。监听器只会在新实例上被调用，而不是在现有实例上被调用，因为现有实例不需要恢复任何东西。
当我停止某个实例时它会被调用吗？
是的，这与上述情况类似。已停止实例的状态将迁移到另一个（或多个）仍在运行的实例，这些实例将恢复状态并因此调用侦听器。
在每种情况下.. 调用哪些方法？
将调用所有三个方法。 “开始”和“结束”回调一次，第三次回调在恢复期间定期报告进度。