Re: kafka streams application design on state stores

2019-10-07 Thread Matthias J. Sax
I am not sure if I understand your scenario. What do you exactly mean by "back ground job" and by "sweeps the records in the store using range calls" ? As you noted, only the `Processor` that have access to the store should write/delete anything from it. You should not try to modify the store from

kafka streams application design on state stores

2019-09-26 Thread ChienHsing Wu
Hi, I am using Kafka Stream's RocksDB state stores in an application and the is a back ground job that sweeps the records in the store using range calls. During processing, we need to ensure that a record is not included in the next range call when that background jobs runs next time. I underst