Unlike most of the recipes in this book, this recipe cannot be run in a Jupyter notebook since we will run the resulting app from the command line.
For this recipe, we will need to import the Faust package:
import faust
We will also need an instance of the default random number generator from the NumPy package:
from numpy.random import default_rng
rng = default_rng(12345)
We will also need to run an instance of a Kafka service on our local machine so that our Faust application can interact with the message broker.
Once you have downloaded Kafka and decompressed the downloaded source, navigate to the folder that the Kafka application can be found in. Open this folder in the terminal. Start the ZooKeeper server using the following command for Linux or Mac:
bin/zookeeper-server-start.sh config/zookeeper.properties
If you're on Windows, use the following command instead:
...