This is a POC to show cause how we can connect the mongo database with Kafka from Jupyter notebook. We are using the following 3 important files to showcause the same.
1. JupyterConsumer.ipynb =>< use to produce the Kafka Topics
2. JupyterProducer.ipynb =>< use to Consume the Kafka Topics
3. TestDataGeneratort.ipynb =>< Use to generate the test data frames.