小编Bal*_*ani的帖子

具有更改日志主题与日志压缩源主题的 Kafka Streams KTable 存储

我正在一个输入主题上构建 KTable,我正在两个 Kafka Stream 应用程序实例上加入 KStream。

KTable 的输入主题已经是一个日志压缩主题。因此,当我的一个应用程序实例出现故障时,另一个实例状态存储似乎通过从输入日志压缩主题中读取来刷新整个状态。

所以不需要为我的 KTable 存储启用日志记录(更改日志)?

我的源输入日志压缩主题可能有数百万条记录,所以如果我启用该 KTable 状态存储的日志记录,它会在失败的情况下改善我的状态存储刷新时间,还是不会产生影响,因为源主题已经被日志压缩了?谢谢!

apache-kafka apache-kafka-streams

5
推荐指数
1
解决办法
2709
查看次数

标签 统计

apache-kafka ×1

apache-kafka-streams ×1