Commit Graph

48 Commits

Author SHA1 Message Date
Loredana Crusoveanu c159de77db Merge pull request #15475 from wynnteo/BAEL-7372
First version
2024-01-04 17:24:13 +02:00
SGWebFreelancer f58b136ff9 Remove the Kafka Producer wrapper, fix the class name 2023-12-27 09:29:52 +08:00
SGWebFreelancer 4a69837406 Fix formatting and added in direct assignment partition 2023-12-25 13:33:22 +08:00
SGWebFreelancer d10d29e0dc Fix comment 2023-12-25 11:25:53 +08:00
SGWebFreelancer c3b97034ed First version 2023-12-24 09:43:23 +08:00
timis1 e6501ada07 JAVA-26705 Upgrade lombok to latest version (#15305)
Co-authored-by: timis1 <noreplay@yahoo.com>
2023-12-03 21:19:12 +02:00
gaepi 7683cff43d JAVA-26724 | kafka testcontainers version update 2023-11-30 10:20:20 +01:00
panos-kakos fcb0f98b92 [JAVA-25997] Clean up 2023-10-15 19:25:42 +03:00
Tapan Avasthi 4050f47183 BAEL-5170: Expose Kafka Consumer Metrics via Actuator Endpoint (#13723)
Co-authored-by: Tapan Avasthi <tavasthi@Tapans-MacBook-Air.local>
2023-03-28 17:45:00 -05:00
anuragkumawat d1144a5605 JAVA-18598 Update Intro to Apache Kafka with Spring article 2023-02-25 15:06:03 +05:30
cesarevalenti90 f396ff0341 BAEL-6057 - Implementing Retry In Kafka Consumer (#13274)
* 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>
2023-01-11 13:25:43 -08:00
cesarevalenti90 c3a0a729db fix retry test (#13267)
Co-authored-by: Cesare <cesare.valenti@hotmail.com>
2023-01-09 13:16:44 -08:00
cesarevalenti90 d6bc6bb5d2 BAEL-6057 - Implementing Retry In Kafka Consumer (#13229)
* 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>
2023-01-02 12:08:01 -08:00
panos-kakos 2beab43784 [JAVA-15471] Changed custom properties with spring properties (#13003)
Co-authored-by: panagiotiskakos <panagiotis.kakos@libra-is.com>
2022-11-17 01:30:33 +05:30
thibault.faure 90ccda2db3 BAEL-5582 add code for the kafka message filtering improvement 2022-08-15 08:48:59 +02:00
Asjad J 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
Muhammad Abdullah Azam Khan 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
Haroon Khan 71c1d44cca [JAVA-12591] Fix Kafka integration test 2022-06-10 12:20:36 +01:00
Haroon Khan 19a08f66d9 [JAVA-12591] Fix Kafka integration test 2022-06-09 23:16:24 +01:00
Loredana Crusoveanu 0e35fc7090 Merge pull request #12088 from waqasakramef/patch-2
Add placeholder
2022-05-27 21:14:33 +03:00
waqasakramef 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
waqasakramef fabe999b3e Removed unused import "EnableAutoConfiguration" 2022-04-19 13:09:20 +05:00
Haroon Khan 400143063a [JAVA-8986] Upgrade spring-kafka to latest Boot version 2022-01-14 10:28:09 +00:00
johnA1331 74c135961b Update README.md 2021-12-23 01:58:49 +08:00
Krzysiek 1215b51c44 JAVA-8794: Leave spring-kafka on Spring Boot 2.5.4 2021-12-14 16:48:53 +01:00
ukhan1980 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
kwoyke 125aa509c0 BAEL-5215: Remove redundant @EnableAutoConfiguration annotations (#11331) 2021-10-17 08:52:26 +02:00
johnA1331 1debf64e6f Update README.md 2021-09-01 22:07:46 +08:00
uzma khan d1be3ca43a [BAEL-4847] Kafka SSL with Spring Boot client 2021-08-21 21:04:34 +01:00
johnA1331 41e789eaef Update README.md 2021-07-07 23:29:24 +08:00
kaushal 9930b4c945 BAEL-4905: Send large messages with Kafka (#10992) 2021-07-03 15:11:51 +02:00
johnA1331 dcf850a45f Update README.md 2021-07-02 05:33:10 +08:00
Tapan Avasthi 52495bef53 BAEL-4855 | Monitor the Kafka Consume Lag in Java (#10866) 2021-06-25 16:22:01 -07:00
kwoyke 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
Loredana Crusoveanu cd7c84e734 Merge pull request #10262 from johnA1331/master
BAEL-29326 - add links to github-baeldung articles
2020-11-19 20:58:30 +02:00
Jonathan Cook 8e477f4d9c BAEL-4706 - Spring Boot with Spring Batch
- Rename testcontainers test to LiveTest
2020-11-18 10:00:24 +01:00
johnA1331 afc3b4e82d Update README.md 2020-11-18 16:57:40 +08:00
Jonathan Cook a26085b266 BAEL-4706 - Spring Boot with Spring Batch
- Rename testcontainers test to LiveTest
2020-11-18 08:30:49 +01:00
Jonathan Cook 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
Jonathan Cook a51e034186 BAEL-4609 - Testing Kafka and Spring Boot 2020-11-13 16:42:33 +01:00
Jonathan Cook eb3631f36f BAEL-4687 Testing Kafka and Spring Boot 2020-11-08 13:23:31 +01:00
kwoyke 6ce7fee3ff BAEL-4541: Fix typos in the spring-kafka module (#9857) 2020-08-13 11:38:50 +02:00
amit.pandey 29dde3b485 updated spring kafka version 2020-05-16 17:06:29 +05:30
Krzysiek 90075c2f38 JAVA-959: Migrate spring-kafka to com.baeldung 2020-03-11 21:34:23 +01:00
Sorin Zamfir 002b937923 BAEL-3185: Fixed formatting 2020-02-27 22:14:17 +02:00
Sorin Zamfir 16b8a61b16 BAEL-3185: Fixed container factory for partition listener 2020-02-27 22:12:39 +02:00
catalin-burcea 153a3923f0 [BAEL-18783] - Fix formatting of POMs 2019-12-06 11:40:56 +02:00
Eric Martin 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