Sample Producer
Kafka sample producer
Sample Consumer
Kafka sample consumer
Sample FileReader
Read data from input.txt and published it to topic
Sample DBConnection
Consumes the message from the topic and save in mysql store
Message
Sample event class
MessageDecoder
Deserializer class for Message Object
MessageEncoder
Serializer class for Message Object
Mysql
Run db-seed.sql