This is a sample Kafka Implementation to understand the working of producer, consumer and broker. This is not the exact implementation but rather an unoptimized and basic one for mere understanding the concept of broker and replaying of messages.
Run DemoApplicationTests to test the functionality.