Publish Subscribe

In this exercise, we will explore the fundamental Enterprise Integration Pattern - Publish/Subscribe. You will implement a custom Kafka producer and
consumer, gaining hands-on experience with Kafka. This is very easy, starting point for everyone who likes to star play with Kafka.
- Clone repository https://github.com/pszymczyk/kafka-native-java-playground
- Checkout step1 branch
- Go to the PublishRunner class, in the main(...) method implement sending messages to the topic step1.
- Send a message in given formatĀ
- My favourite number is $randomNumber
- My favourite number is $randomNumber
- Display in the application logs details of each message sent: topic, partition, offset
- Go to the SubscribeRunner class, in main(...) method implement consumer loop, use given methods:
- subscribe(...)
- poll(...)
- Display in the application logs details of each message read: topic, partition, offset
- Run PublishRunner and SubscribeRunner
- Check the application logs