Real Time Kafka Chat

Technologies

Kafka is used for message streaming and storage. Python library names are kafka-python and aiokafka(for asyncio integration)
Websocket is used for showing and sending messages without a reload need. (websockets package)
Asyncio and aiokafka is used for asynchronous usage of Kafka.

Running

Install docker and docker-compose
Run docker-compose up -d in root folder
Go to localhost:8080
You can use more than one browser to test, or multiple tabs in a single browser
Keep in mind that it can take 30 seconds for kafka and websocket server to start.

Demo