A very simple project showing the addition of a message to a Kafka topic, the consumption of the same message and the insertion of that message into MongoDB.
Startup:
- Start mongo:
mongod - Start the Kafka server:
kafka-server-start /usr/local/etc/kafka/server.properties - Create the Kafka topic:
kafka-topics --list --zookeeper localhost --topic metamorphosis - Start the producer:
python kafka-producer - Start the consumer:
python kafka-consumer