To run the inferences, ensure that you have an environment with PySpark and other relevant libraries installed and directly run the notebook.
To run kafka, start the Zookeeper Service
$ bin/zookeeper-server-start.sh config/zookeeper.properties
Start the Broker Service
$ bin/kafka-server-start.sh config/server.properties
Create a topic (one time only)
$ bin/kafka-topics.sh --create --topic accident_tmp_input --bootstrap-server localhost:9092
Run the KafkaProducer notebook first and then the KafkaConsumer notebook. Your output should be accumulated from time to time in a HTML file.