Now, let's do some python with our kafka. (Hey, your kafka and zookeeper should still be running.) (and if not, start 'em up again) in a directory named (lines10) in your projects somewhere, create a file producer.py from time import sleep from json import dumps from kafka import KafkaProducer