小编kut*_*uti的帖子

为什么 kafka 流状态目录在 /tmp/kafka-streams 中?

我不确定它是否已经得到了回答。由于我没有得到适当的解释,在这里发布我的问题。

为什么 kafka 流state.dir存储在/tmp/kafka-streams?

我知道我可以通过在流代码中提供状态目录配置来更改路径,如下所示

StreamsConfig.STATE_DIR_CONFIG,"/var/abc-Streams"

但是更改目录会有什么影响吗?

或者

我可以在应用程序目录中而不是在/tmp.

根据融合文档,对于: Stateful操作:

automatically creates and manages such state stores when you are calling stateful operators such as count() or aggregate(), or when you are windowing a stream

但没有具体说明它的确切存储位置。

有什么想法吗?

apache-kafka rocksdb apache-kafka-streams

4
推荐指数
1
解决办法
4619
查看次数