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

4246 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Deyan Yurukov
a526bab311 Removes deprecated DescribeTopicsResult method 
Signed-off-by: Deyan Yurukov <deyan.yurukov@gmail.com>
Resolves #3111
 2025-04-28 10:15:18 +02:00
spring-builds
bfbf3a8a2e Bumping versions 2025-04-26 14:59:42 +00:00
Oleg Zhurakousky
52913cef03 GH-3108 Fix links in docs 
Resolves #3108
 2025-04-22 15:11:53 +02:00
Oleg Zhurakousky
98c6087b65 Fix Kafka test 2025-04-16 19:40:24 +02:00
Oleg Zhurakousky
27c68b267b GH-3086 Fix naming for explicit bindings that are not backed by a function 2025-04-15 15:04:56 +02:00
Oleg Zhurakousky
143ac8208a GH-3086 Add documentation for defining new bindings 
Add documentation for defining new bindings via BindingsLifecycleController

Resolves #3086
 2025-04-14 09:19:42 +02:00
Oleg Zhurakousky
af1b8a3071 GH-3067 Adjust phase of StreamsBuilderFactoryManager 
Adjust phase of StreamsBuilderFactoryManager to be lower than WebServerGracefulShutdownLifecycle

Resolves #3067
 2025-04-14 08:34:29 +02:00
Oleg Zhurakousky
4247670032 Fix formatting 2025-04-11 13:23:31 +02:00
Andy Palmer
2e290aa7d0 GH-3103 Fix the retrieval of the schema version registered on serializing an Avro message with the ConfluentSchemaRegistryClient 
Signed-off-by: Andy Palmer <andy.palmer@aexp.com>

Resolves #3103
Resolves #3107
 2025-04-08 18:21:46 +02:00
spring-builds
18bc7d1fe7 Going back to snapshots 2025-04-07 10:26:31 +00:00
spring-builds
177f16745d Update SNAPSHOT to 4.3.0-M3 2025-04-07 10:24:02 +00:00
Oleg Zhurakousky
da58e42648 GH-3086 Define explicit defineInput/Output binding methods 
Also changed signature to return properties for convinience
Added test
 2025-04-04 15:21:58 +02:00
Oleg Zhurakousky
3261108285 GH-3086 Initial functionality to define bindings dynamically 2025-04-01 16:36:14 +02:00
Soby Chacko
5970a3a171 Change test port to non-default (8990 -> 8991) in schema registry server test 
This helps with running tests in parallel (for example, when using mvnd)

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-03-28 16:01:19 -04:00
Oleg Zhurakousky
1a01c6cbcc GH-3105 Fix hashCode calculation for StreamBridge function 
This would ensure that there are no collisions in hashCode calculation for cases where partitionKeyExpression is used in one of the bindings while partitionCount of any of the bindings may result in teh overall StreamBridge function having the same  hashCode

Resolves #3105
 2025-03-27 21:59:39 +01:00
Oleg Zhurakousky
1fd331f5bf GH-3104 fix formatting 2025-03-27 17:04:09 +01:00
Oleg Zhurakousky
547a435b1d GH-3104 Add JsonGetter to show SpEL expression as String 
This is specifically done for actuator binding endpoint to avoid type conversion

Resolves #3104
 2025-03-27 16:49:12 +01:00
Oleg Zhurakousky
91064171e2 GH-3101 Make Binder an instance variable 
Resolves #3101
 2025-03-25 15:12:01 +01:00
Oleg Zhurakousky
f48982971a Fix formatting 2025-03-24 23:41:15 +01:00
2tsumo-hitori
bb3324a5b5 Replaced ReentrantLock with ConcurrentHashMap.computeIfAbsent() 
to improve performance in StreamBridge.send() method.

- Avoids unnecessary locking overhead
- Improves concurrency and reduces contention
- Enhances throughput for high-load scenarios

Signed-off-by: 2tsumo-hitori <audghks1996@naver.com>
 2025-03-24 23:41:07 +01:00
spring-builds
c733627d8c Bumping versions 2025-03-22 15:02:01 +00:00
Oleg Zhurakousky
8eebd773fc GH-3100 Move Brave and Actuator dependenies 
Moved Brane and Actuator dependencies from test-binder to integration tests under test scope

Resolves #3100
 2025-03-20 13:12:42 +01:00
Oleg Zhurakousky
8ff2757941 Merge pull request #3096 from wwalters12/patch-1 
Fix typo in record-serialization-and-deserialization doc
 2025-03-13 16:59:24 +01:00
Soby Chacko
d6cc07df97 GH-3090: Ensure client factory customizers are applied before transaction manager creation 
Fixes: #3090

Issue: https://github.com/spring-cloud/spring-cloud-stream/issues/3090

Fixes issue where KafkaBinderConfiguration would add customizers after the
transaction manager was already created.

The KafkaMessageChannelBinder was initializing the transaction manager in the
constructor before client factory customizers were added, which meant the customizers
were never applied to the producer factory used by the transaction manager.

- Moves transaction manager initialization from the constructor to the onInit() method
- Leverages the existing InitializingBean lifecycle to ensure customizers are applied
  before the transaction manager is created
- Adds comprehensive test coverage to verify the fix in the binder and via auto-configuration

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>

Resolves #3091
 2025-03-13 16:58:26 +01:00
Soby Chacko
525a5c1220 Update actions/upload-artifact@v4 in CI PR build 
Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-03-13 09:57:17 -04:00
Soby Chacko
dcd34d1593 Setup Maven cache gh action used in PR CI build to v4 
Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-03-13 09:51:24 -04:00
William Walters (He/Him)
8990e7e4b9 Fix typo in record-serialization-and-deserialization doc 
Should be `useNativeEncoding`, not `nativeEncoding`: https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_producer_properties

Signed-off-by: William Walters (He/Him) <william.h.walters12@gmail.com>
 2025-03-11 15:58:45 -05:00
Soby Chacko
b342c2157f Document exception retry behavior for Kafka transactions 
Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-03-10 17:11:16 -04:00
DidierLoiseau
48659f9e92 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 16:51:30 -04:00
akenra
e0fdfdecc8 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 22:42:56 +05:00
spring-builds
a5c53f735f Going back to snapshots 2025-02-27 15:46:58 +00:00
spring-builds
1a4eadd8fe Update SNAPSHOT to 4.3.0-M2 2025-02-27 15:44:27 +00:00
Oleg Zhurakousky
afc8fa29da GH-3076 Change 'bindings' to ConcurrentHashMap in 'BindingServiceProperties' 
Using 'ConcurrentSkipListMap' was causing significant performance issues

Resolves #3076
 2025-02-26 08:39:00 +01:00
spring-builds
d847f1cfaa Bumping versions 2025-02-22 15:02:27 +00:00
spencergibb
9889362f44 Formatting 2025-02-21 11:51:18 -05:00
Oleg Zhurakousky
c6c5e09c5d GH-3085 add test configuration file 2025-02-21 15:15:09 +01:00
Oleg Zhurakousky
3e624057a7 GH-3085 Add Number and Boolean Spel converter 
Refactor SpelConverter into an abstract class

Resolves #3085
 2025-02-21 15:05:51 +01:00
spencergibb
648269ca93 Revert "Temporarily upgrade to spring-framework-bom:6.2.4-SNAPSHOT" 
This reverts commit 0716ec3a4d.
 2025-02-19 13:00:04 -05:00
spencergibb
ea074ac414 Sets proxyBeanMethods = false on test config 2025-02-18 11:49:07 -05:00
spencergibb
0716ec3a4d Temporarily upgrade to spring-framework-bom:6.2.4-SNAPSHOT 2025-02-18 11:38:42 -05:00
Oleg Zhurakousky
fb3c889c9c Merge pull request #3079 from StevenPG/bugfix/handle-null-result-on-function-invocation-streambridge 
Add Null Handling for FunctionToInvoke in StreamBridge along with Test
 2025-02-11 16:50:00 +01:00
Steven Gantz
25427bc718 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-10 20:59:43 -05: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
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
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