SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
4,219 Commits 28 Branches 0 Tags
9fc527da2fef1e7c3c423e6bb76f855b5ed9c3ca
Commit Graph

4219 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
spring-builds
9fc527da2f Update SNAPSHOT to 4.2.1 2025-03-18 22:16:59 +00:00
spring-builds
9aeba8a31f Bumping versions 2025-03-18 17:25:51 +00:00
spencergibb
9561625ef7 Sets proxyBeanMethods = false on test config 2025-03-18 11:16:49 -04:00
Soby Chacko
6a8fb64c02 Document exception retry behavior for Kafka transactions 
Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-03-10 17:23:31 -04:00
DidierLoiseau
463ca2269b Fixes: #3066 
Issue link: https://github.com/spring-cloud/spring-cloud-stream/issues/3066

Signed-off-by: DidierLoiseau <didierloiseau+github@gmail.com>
 2025-03-10 17:22:51 -04:00
akenra
9a311e1707 fix(kafka-topic-provisioner): Prevent resource leak on binding producer to KafkaMessageChannelBinder 
- Producer that fetches partition info now initializes within a try-with-resources block
- If exceptions occur on calling producer.partitionsFor(topicName), it's now properly closed and resources are released

Signed-off-by: akenra <37288280+akenra@users.noreply.github.com>
 2025-03-07 13:38:02 -05:00
Oleg Zhurakousky
47cb7abe07 GH-3076 Change 'bindings' to ConcurrentHashMap in 'BindingServiceProperties' 
Using 'ConcurrentSkipListMap' was causing significant performance issues

Resolves #3076
 2025-02-26 08:38:25 +01:00
spencergibb
1bfe9ff342 Formatting 2025-02-21 11:48:35 -05:00
Oleg Zhurakousky
ec20f1391b GH-3085 add test configuration file 2025-02-21 15:16:00 +01:00
Oleg Zhurakousky
78427b0ef2 GH-3085 Add Number and Boolean Spel converter 
Refactor SpelConverter into an abstract class

Resolves #3085
 2025-02-21 15:03:18 +01:00
spring-builds
dc164fe3c0 Bumping versions 2025-02-11 17:34:51 +00:00
Steven Gantz
12117c6049 Add additional test and error handling 
Handle when functionToInvoke returns null

add link to issue

Signed-off-by: Steven Gantz <steven.p.gantz@gmail.com>
 2025-02-11 16:52:07 +01:00
Oleg Zhurakousky
321d7afdcd Merge remote-tracking branch 'upstream/main' into 4.2.x 2025-02-10 14:22:06 +01:00
Oleg Zhurakousky
7178dbfdac Merge pull request #3074 from tautologicc/fix-docs-typo 
Fix typos in documentation
 2025-02-03 08:21:17 +01:00
F. Emerson
fe6a0ab8b7 Fix typos in documentation 
Signed-off-by: F. Emerson <t@utologi.cc>
 2025-01-30 18:21:41 -03:00
Oleg Zhurakousky
0f68d94c5b GH-3071 Add documentation for accessing producer/consumer properties 
Resolves #3071
 2025-01-30 15:36:01 +01:00
Oleg Zhurakousky
b5b8b3089d GH-3071 Add documentation for accessing producer/consumer properties 
Resolves #3071
 2025-01-30 15:35:33 +01:00
spring-builds
dc3669bfcf Going back to snapshots 2025-01-30 03:00:53 +00:00
spring-builds
4edccc3b56 Update SNAPSHOT to 4.3.0-M1 2025-01-30 02:58:18 +00:00
Oleg Zhurakousky
299a80cd48 GH-3071 Add support for accessing producer/consumer properties 2025-01-28 09:39:55 +01:00
Oleg Zhurakousky
adddeffbf3 GH-3071 Add support for accessing producer/consumer properties 2025-01-28 09:36:58 +01:00
spring-builds
fcd7cba51d Bumping versions 2025-01-18 15:09:52 +00:00
Soby Chacko
8954aaf336 Bumping next version to 4.3.0-SNAPSHOT 2025-01-17 11:06:07 -05:00
Oleg Zhurakousky
0c29e74bb4 Add DCO.yaml 2025-01-17 14:34:51 +01:00
Oleg Zhurakousky
70b8037966 Merge pull request #3064 from artembilan/GH-3062 
GH-3062: Fix `KafkaBinderMetrics` for resource leaks
 2025-01-08 11:25:10 +01:00
Artem Bilan
f259c55704 * Implement SmartLifecycle contract on the DefaultBinderFactory. 
When CRaC checkpoint is requested, the binder contexts must be stopped as well,
which includes all their managed beans, respectively.
 2025-01-07 14:22:23 -05:00
Oleg Zhurakousky
534277ff3d GH-3065 Fix lazy initialization for Kafka streams configuration classes 
Resolves #3065
 2025-01-06 15:07:27 +01:00
Artem Bilan
90afffb273 GH-3062: Fix KafkaBinderMetrics for resource leaks 
Fixes: https://github.com/spring-cloud/spring-cloud-stream/issues/3062

The `KafkaBinderMetrics` creates `KafkaConsumer` instances and schedule the fix rate
task for them, but never closes them even when the `scheduler` is shut downed

* Implement a `Lifecycle` contract in the `KafkaBinderMetrics` and call `close()`
from the `stop()` to satisfy CRaC resource management expectations.
* Also close all the `KafkaConsumer` instances from the `metadataConsumers`

**Cherry-pick to `4.1.x`**
 2025-01-03 14:43:28 -05:00
Oleg Zhurakousky
af6b4ff9eb Merge pull request #3063 from destan/patch-1 
Clarify that having a custom error handler disables auto send to DLQ
 2025-01-03 17:51:20 +01:00
Destan Sarpkaya
9b1fbfb59d Clarify that having a custom error handler disables auto send to DLQ 2025-01-03 16:40:39 +03:00
Oleg Zhurakousky
3f8b7003e7 GH-3054 Clear channel cache in StreamBridge during the refresh 
Resolves #3054
 2024-12-19 12:06:00 +01:00
spencergibb
637636dfa8 Adds @ConditionalOnMissingBean to test binder ObservationRegistry 2024-12-12 10:43:44 -05:00
Oleg Zhurakousky
ad2a654160 GH-3055 Polish 2024-12-12 14:27:58 +01:00
Oleg Zhurakousky
e8bed37161 GH-3055 Add BinderHeaderMapper to reactive Kafka binder 
Resolves #3055
 2024-12-12 13:49:36 +01:00
Oleg Zhurakousky
aa2b309e66 GH-3030 Modify InputBindingLifecycle phase 
Resolves #3030
 2024-12-11 13:17:38 +01:00
Oleg Zhurakousky
2f9be858d7 GH-3055 Add additional types for toString() serialization 
Add additional types for toString() serialization to Kafka's  to ensure propper serialization/deserialization of message header values.

Resolves #3055
 2024-12-11 13:08:41 +01:00
Oleg Zhurakousky
4fb9a16c99 Fix tests after Observation feature was added to StreamBridge 2024-12-09 15:48:59 +01:00
Oleg Zhurakousky
1349adaba3 GH-3053 Fix regression with 'default' properties validation 
Resolves #3053
 2024-12-09 13:52:49 +01:00
Oleg Zhurakousky
c67fca58c4 GH-3052 Add to additional-spring-configuration-metadata.json 
Resolves #3052
 2024-12-04 16:16:44 +01:00
Agustino Lim
a88c34fc9f GH-3033: Register ObservationRegistry for Dynamic MessageChannels 
Fixes: gh-3033

* ensure `ObservationRegistry` is registered on dynamically created `MessageChannel` instances in `StreamBridge`
 2024-12-04 13:13:20 +01:00
Oleg Zhurakousky
f392488dae Merge pull request #3044 from omercelikceng/fix-typo-docs 
Fix typo in docs for rabbit and spring cloud stream sections
 2024-12-04 13:12:26 +01:00
Oleg Zhurakousky
9bd2c87bb1 Merge pull request #3043 from omercelikceng/fix-typo 
Fix typo in docs
 2024-12-04 13:12:02 +01:00
spring-builds
2aa8d495cd Bumping dependency versions after release 2024-12-03 00:23:06 +00:00
spring-builds
f1e6c87814 Bumping versions to 4.2.1-SNAPSHOT after release 2024-12-03 00:21:56 +00:00
spring-builds
f03ea2582a Going back to snapshots 2024-12-03 00:21:54 +00:00
spring-builds
b26353cfcc Update SNAPSHOT to 4.2.0 2024-12-03 00:18:38 +00:00
spring-builds
8cdde2e3fd Bumping versions 2024-11-23 14:13:43 +00:00
Ömer Çelik
94f061d4cc Fix typo in docs for rabbit and spring cloud stream sections 2024-11-18 18:14:27 +03:00
Ömer Çelik
7c396a602c Fix typo in docs 2024-11-18 18:05:47 +03:00
Oleg Zhurakousky
a67de87e42 Merge pull request #3029 from beni0888/fix-typo-overview-error-handling 
Fix typo in overview-error-handling.adoc
 2024-11-18 14:09:43 +01:00