* BAEL-6057 - Implementing Retry In Kafka Consumer
(moved code example to new module)
* BAEL-6057 - Implementing Retry In Kafka Consumer
(fix on README.md)
Co-authored-by: Cesare <cesare.valenti@hotmail.com>
* Added test class for a simple shallow copy and deep copy
* Added test class for a simple shallow copy and deep copy
* refactor naming of test method
* formatted
* refactor test whenIsAShallowCopyDoneByCopyConstructor_thenImmutableObjectWillNotChange
* Renamed package and added md file
* refactor README.md
* first push
* refactor
* Revert "refactor README.md"
This reverts commit eae77c453ba0bf2af62bad52dc1ed61d07931e34.
* Revert "Renamed package and added md file"
This reverts commit 42c6f97cbde39cc0a5e0bacf34f86a32ded4f4aa.
* Revert "refactor test whenIsAShallowCopyDoneByCopyConstructor_thenImmutableObjectWillNotChange"
This reverts commit 44fb57fe2b51857f960dc216d33508e718e5414f.
* Revert "formatted"
This reverts commit 44be87ef25e566b8e9175cb0fdeed7f0ef485dd3.
* Revert "refactor naming of test method"
This reverts commit 6133c31057e39b19c4978f960cda1c0ba5559aae.
* Revert "Added test class for a simple shallow copy and deep copy"
This reverts commit 2cae083578883ae693d1c5e76fd4948e213e9ea0.
* Revert "Added test class for a simple shallow copy and deep copy"
This reverts commit f43312e2c1979410409f46020a3f7d555e11e966.
* Merge prohect java-supplier-callable to project core-java-lambdas
* adjusted package name
* removed AbstractAgeCalculator.java
* added test for supplier-callable
* first push for article "Implementing Retry In Kafka Consumer"
Co-authored-by: Cesare <cesare.valenti@hotmail.com>
* 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 28801f85174af8bf2d2bb89e1fb39b52c49a6cf0.
* 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}"
Tapan Avasthi
anuragkumawat
cesarevalenti90
panos-kakos
thibault.faure
Muhammad Abdullah Azam Khan
Haroon Khan
Loredana Crusoveanu
waqasakramef
ukhan1980
kwoyke
uzma khan
kaushal
Jonathan Cook
Sorin Zamfir
Eric Martin