vineetgoel1992

3 ms·

1. 1.▲
   by vineetgoel1992 8y ago

   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 seconds, whichever happe
2. 2.▲
   by vineetgoel1992 8y ago

   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 for teams to star
3. 3.▲
   by vineetgoel1992 8y ago

   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 log-compacted kafka topic
4. 4.▲
   by vineetgoel1992 8y ago

   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 simply a topology of c