Faust: Performing Operations & Maintaining State Using Tables

Faust streams support a wide range of operations. In this course youll learn how to perform several of these. Youll also work with Faust tables – which store state in the form of key-value pairs and allow for the recovery of failed processing making Faust fault-tolerant. Youll start off by using the group by operation to designate a key used to repartition an input stream and create a new topic in Kafka. Youll then use the items() operation to access the key and message value and take() operation to buffer multiple elements in a stream. Next youll work with tables to conduct stateful stream processing illustrating how table data is stored in an embedded RocksDB database. When youve finished this course youll be able to apply a wide range of operations on input streams and perform stateful stream processing using tables.