全局状态存储与kafka中的普通状态存储有何不同？

Question

全局状态存储与正常状态存储有何不同？

全局状态存储是否在不同计算机上运行的所有实例中都有数据副本？在重新启动的情况下它的行为，因为在我的场景中全局状态存储不使用任何更改日志主题进行还原，因此全局存储中的源主题没有密钥。

Answer 1

1. 全局状态存储是否在不同计算机上运行的所有实例中都有数据副本？

   是

2. 在重新启动的情况下的行为，因为在我的场景中全局状态存储不使用任何更改日志主题进行还原，因此全局存储中的源主题没有密钥：
   • GlobalKTable默认情况下禁用日志记录，因此它不会将changelog推送到GlobalKTable的changelog主题。您必须从启用日志压缩的输入主题中重新填充数据至GlobalKTable（cleanup.policy = compact），该消息的密钥是您要在GlobalKTable]中查找的密钥
   • 在我的场景中，全局存储中的源主题没有密钥：您必须使用KeyValueMapper将源主题映射到上面提到的新主题，并在输出主题上启用日志压缩。