brew install kafka
brew services start zookeeper
brew services start kafka
telnet localhost 2181
telnet localhost 9092
pip install -r requirements.txt
python producer.py
python consumer.py
kafka-run-class kafka.tools.ReplayLogProducer --broker-list localhost:9092 --inputtopic events.created