In addition to that you can have an arbitrary method run at an interval using the app.timer decorator. You can use this to flush every n seconds. You could also use stream.take to read batches of messages (or wait t…
Not having to use systems such as Yarn/Mesos was a big motivation for us. Faust works well with any existing deployment systems (we currently use supervisor with EC2 instances) you may have and definitely made it easy…
We have been using RocksDB for some time and it works fairly well. While we haven't seen any corruption yet, as you correctly pointed out, it is definitely a possibility. We use RocksDB only as a cache and use…
Hi, thanks for the comments. My name is Vineet and I am a co-creator of this project along with Ask. We do plan on adding support for Kafka exactly once semantics to Faust. As @dleclere pointed out, streaming apps are…
In addition to that you can have an arbitrary method run at an interval using the app.timer decorator. You can use this to flush every n seconds. You could also use stream.take to read batches of messages (or wait t…
Not having to use systems such as Yarn/Mesos was a big motivation for us. Faust works well with any existing deployment systems (we currently use supervisor with EC2 instances) you may have and definitely made it easy…
We have been using RocksDB for some time and it works fairly well. While we haven't seen any corruption yet, as you correctly pointed out, it is definitely a possibility. We use RocksDB only as a cache and use…
Hi, thanks for the comments. My name is Vineet and I am a co-creator of this project along with Ask. We do plan on adding support for Kafka exactly once semantics to Faust. As @dleclere pointed out, streaming apps are…