我不确定它是否已经得到了回答。由于我没有得到适当的解释,在这里发布我的问题。
为什么 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
但没有具体说明它的确切存储位置。
有什么想法吗?