* Update KafkaApplication.java
Added partition offset to the listener so that it can start consuming the messages from the beginning of the topic.
* Revert "Update KafkaApplication.java"
This reverts commit 28801f8517.
* Counting Messages
1. Counting messages from Producer offset
2. Counting messages from Consumer
3. Rest APIs to view the count
* Refactoring
* Adding 3rd programmatic method to count number of messages in Kafka topic
* Removing irrelevant code
* Server port removed
The placeholder is mentioned in the kafkaConsumer.java but didn't defined in the applications.prop. So we need to defined that.
Current exception is as follow.
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaConsumer' defined in file [/Users/mac/Library/Mobile Documents/com~apple~CloudDocs/development/kafka-poc/producer/target/classes/com/ef/kafka/embedded/KafkaConsumer.class]: Initialization of bean failed; nested exception is java.lang.IllegalArgumentException: Could not resolve placeholder 'test.topic' in value "${test.topic}"
* Renamed Integrationtests that needed the project (or related project, in case of client-server) as LiveTests
* Fixed migration of mustache module to make it compatible with spring-boot 2.1
