> when a stream app get restarted, can the store data >> directly loaded from this folder?
Yes. That's the purpose of local state. > because I see there is very heavy traffic >> on the network to read from broker, assuming it's trying to rebuild the >> store. This should only happen if the local store was corrupted (or deleted). Note, that /tmp is not a safe location as it might be cleared by the OS. For production use cases, it is highly recommended to reconfigure the state directory via parameter `state.dir`. -Matthias On 2/20/19 1:53 PM, Nan Xu wrote: > just a general question about the rocksdb in the Kafka stream, I see there > is a folder at /tmp/kafka-stream/, which is used by the rocksdb in the > kafka stream. so when a stream app get restarted, can the store data > directly loaded from this folder? because I see there is very heavy traffic > on the network to read from broker, assuming it's trying to rebuild the > store. if so, what's the purpose of this rocksdb folder? > > Thanks, > Nan >
signature.asc
Description: OpenPGP digital signature
