kafka_training Simple code for publishing/consuming messages to/from Dolead's Kafka cluster Usage python my_consumer.py will initialize a consumer that will start listening for any message python my_producer.py will publish sample messages