我正在一个输入主题上构建 KTable,我正在两个 Kafka Stream 应用程序实例上加入 KStream。
KTable 的输入主题已经是一个日志压缩主题。因此,当我的一个应用程序实例出现故障时,另一个实例状态存储似乎通过从输入日志压缩主题中读取来刷新整个状态。
所以不需要为我的 KTable 存储启用日志记录(更改日志)?
我的源输入日志压缩主题可能有数百万条记录,所以如果我启用该 KTable 状态存储的日志记录,它会在失败的情况下改善我的状态存储刷新时间,还是不会产生影响,因为源主题已经被日志压缩了?谢谢!