90ccda2db3
BAEL-5582 add code for the kafka message filtering improvement
2022-08-15 08:48:59 +02:00
80de64e44d
Updated README.md
...
added link back to the article: https://www.baeldung.com/java-kafka-count-topic-messages
2022-08-10 09:40:12 +05:00
ef0b7ea20c
Update KafkaApplication.java ( #12424 )
...
* 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
2022-08-08 09:33:20 +05:30
71c1d44cca
[JAVA-12591] Fix Kafka integration test
2022-06-10 12:20:36 +01:00
19a08f66d9
[JAVA-12591] Fix Kafka integration test
2022-06-09 23:16:24 +01:00
0e35fc7090
Merge pull request #12088 from waqasakramef/patch-2
...
Add placeholder
2022-05-27 21:14:33 +03:00
c53a703587
Add placeholder
...
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}"
2022-04-19 13:22:22 +05:00
fabe999b3e
Removed unused import "EnableAutoConfiguration"
2022-04-19 13:09:20 +05:00
400143063a
[JAVA-8986] Upgrade spring-kafka to latest Boot version
2022-01-14 10:28:09 +00:00
74c135961b
Update README.md
2021-12-23 01:58:49 +08:00
1215b51c44
JAVA-8794: Leave spring-kafka on Spring Boot 2.5.4
2021-12-14 16:48:53 +01:00
c50e8d7425
[BAEL-5223] Add code for Spring Boot Streams article ( #11568 )
...
Co-authored-by: uzma khan <uzma.khan@nominet.uk>
2021-12-10 22:58:11 -06:00
125aa509c0
BAEL-5215: Remove redundant @EnableAutoConfiguration annotations ( #11331 )
2021-10-17 08:52:26 +02:00
1debf64e6f
Update README.md
2021-09-01 22:07:46 +08:00
d1be3ca43a
[BAEL-4847] Kafka SSL with Spring Boot client
2021-08-21 21:04:34 +01:00
41e789eaef
Update README.md
2021-07-07 23:29:24 +08:00
9930b4c945
BAEL-4905: Send large messages with Kafka ( #10992 )
2021-07-03 15:11:51 +02:00
dcf850a45f
Update README.md
2021-07-02 05:33:10 +08:00
52495bef53
BAEL-4855 | Monitor the Kafka Consume Lag in Java ( #10866 )
2021-06-25 16:22:01 -07:00
eb1f4e1e90
JAVA-5875: Upgrade Spring Boot to 2.5.1 ( #10956 )
...
* JAVA-5875: Upgrade Spring Boot to 2.5.1
* JAVA-5875: Leave jta module on Spring Boot 2.4.7
* JAVA-5875: Update spring-boot-persistence-mongodb to use embedded Mongo 3.0
* JAVA-5875: Leave spring-data-dynamodb on Spring Boot 2.4.7
* JAVA-5875: ErrorController#getErrorPath has been removed
* JAVA-5875: Fix SQL Script DataSource Initialization
* JAVA-5875: ErrorController#getErrorPath has been removed
* JAVA-5875: Fix RepositoryRestConfigurer
* JAVA-5875: Fix issues caused by rest-assured upgrade
* JAVA-5875: Upgrade spring-cloud-dependencies to 2020.0.3
* JAVA-5875: Leave spring-boot-keycloak on Spring Boot 2.4.7
* JAVA-5875: Fix data.sql script initialization
* JAVA-5875: Leave spring-security-legacy-oidc on Spring Boot 2.4.7
* JAVA-5875: Fix data.sql script initialization
* JAVA-5875: Fix data.sql script initialization
* JAVA-5875: Update de.flapdoodle.embed.mongo dependency
* JAVA-5875: Upgrade spring-cloud-dependencies to 2020.0.3
* JAVA-5875: Update Spring Cloud dependencies
* JAVA-5875: Update cloud dependencies
* JAVA-5875: Defer datasource initialization
* JAVA-5875: Fix rest assured version
* JAVA-5875: Fix Spring Batch serialization issue
* JAVA-5875: Update Spring Cloud Stream version
* JAVA-5875: Update Spring Kafka version
* JAVA-5875: Leave spring-zuul-rate-limiting on Spring Boot 2.4.7
Co-authored-by: Krzysztof Woyke <krzysztof.woyke.sp@lhsystems.com>
2021-06-26 01:20:37 +05:30
cd7c84e734
Merge pull request #10262 from johnA1331/master
...
BAEL-29326 - add links to github-baeldung articles
2020-11-19 20:58:30 +02:00
8e477f4d9c
BAEL-4706 - Spring Boot with Spring Batch
...
- Rename testcontainers test to LiveTest
2020-11-18 10:00:24 +01:00
afc3b4e82d
Update README.md
2020-11-18 16:57:40 +08:00
a26085b266
BAEL-4706 - Spring Boot with Spring Batch
...
- Rename testcontainers test to LiveTest
2020-11-18 08:30:49 +01:00
cfb424f9d1
BAEL-4609 - Testing Kafka and Spring Boot ( #10249 )
...
* BAEL-4437 - System Rules
* BAEL-4687 Testing Kafka and Spring Boot
* BAEL-4609 - Testing Kafka and Spring Boot
Co-authored-by: Jonathan Cook <jcook@sciops.esa.int>
2020-11-13 10:31:59 -08:00
a51e034186
BAEL-4609 - Testing Kafka and Spring Boot
2020-11-13 16:42:33 +01:00
eb3631f36f
BAEL-4687 Testing Kafka and Spring Boot
2020-11-08 13:23:31 +01:00
6ce7fee3ff
BAEL-4541: Fix typos in the spring-kafka module ( #9857 )
2020-08-13 11:38:50 +02:00
29dde3b485
updated spring kafka version
2020-05-16 17:06:29 +05:30
90075c2f38
JAVA-959: Migrate spring-kafka to com.baeldung
2020-03-11 21:34:23 +01:00
002b937923
BAEL-3185: Fixed formatting
2020-02-27 22:14:17 +02:00
16b8a61b16
BAEL-3185: Fixed container factory for partition listener
2020-02-27 22:12:39 +02:00
153a3923f0
[BAEL-18783] - Fix formatting of POMs
2019-12-06 11:40:56 +02:00
3225470df5
Merge pull request #8125 from eugenp/revert-8119-BAEL-3275-2
...
Revert "BAEL-3275: Using blocking queue for pub-sub"
2019-10-31 20:43:47 -05:00
thibault.faure
Asjad J
Muhammad Abdullah Azam Khan
Haroon Khan
Loredana Crusoveanu
waqasakramef
johnA1331
Krzysiek
ukhan1980
uzma khan
kaushal
Tapan Avasthi
Jonathan Cook
Jonathan Cook
amit.pandey
Sorin Zamfir
catalin-burcea
Eric Martin