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

4267 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
spring-builds
70b070d4e7 Going back to snapshots 2025-05-29 00:10:52 +00:00
spring-builds
e8ab3f9388 Update SNAPSHOT to 4.3.0 2025-05-29 00:07:17 +00:00
Oleg Zhurakousky
a919d434c3 Remove Boot Maven Plugin from schema-registry-server 2025-05-27 12:30:51 +02:00
Soby Chacko
5425cdd270 Deprecate Reactive Kafka Binder in 4.3.0 
See details here: https://spring.io/blog/2025/05/20/reactor-kafka-discontinued

Reactive Kafka binder will be compleltely removed in a future release

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-05-23 19:40:01 -04:00
spring-builds
859ac8d1ca Bumping versions 2025-05-23 15:03:35 +00:00
Oleg Zhurakousky
d1f01629b4 Fix dependncies in Rabbit core 2025-05-16 18:20:57 +02:00
Oleg Zhurakousky
bf447ffaad Revert "Fix dependncies in Rabbit core" 
This reverts commit 7fd161963a.
 2025-05-16 18:20:32 +02:00
Oleg Zhurakousky
7fd161963a Fix dependncies in Rabbit core 2025-05-14 18:28:48 +02:00
spring-builds
36ea048d00 Bumping versions 2025-05-11 15:00:21 +00:00
Oleg Zhurakousky
e6dc0bc342 GH-2814 Add version numbers of currently ruunning stream/function 
Version information is addedc to the standard Spring Boot banner

Resolves #2814
 2025-05-07 16:35:40 +02:00
Oleg Zhurakousky
f919d266d8 GH-3039 Update documentation to explaine usage of Spring/Boot core propertyannotations 
Resolves #3039
 2025-05-06 17:07:34 +02:00
spring-builds
1e401c8921 Going back to snapshots 2025-05-01 11:46:50 +00:00
spring-builds
b56b9f880b Update SNAPSHOT to 4.3.0-RC1 2025-05-01 11:44:19 +00:00
Oleg Zhurakousky
bfad60c609 GH-3030 Update phase of InputBindingLifecycle 2025-04-30 10:07:04 +02:00
Oleg Zhurakousky
2656bf7f4f GH-3083 Fix lifecycle of reactive producer 
Ensure that the corresponding FluxMessageChannel gets properly destroyed during application shutdown

Resolves #3083
 2025-04-30 08:59:54 +02:00
Oleg Zhurakousky
4786fd4405 Fix docs 2025-04-28 19:09:00 +02:00
Oleg Zhurakousky
d4859e5794 GH-3106 Add documentation describing why StreamBridge does not cache bindings 
Resolves #3106
 2025-04-28 15:20:31 +02:00
Oleg Zhurakousky
ff98fb9e44 Polish previosu commit 2025-04-28 14:06:05 +02:00
Oleg Zhurakousky
165643cd6e GH-3109 Add documentation to explain explicit binding naming convention 
Resolves #3109
 2025-04-28 14:02:22 +02:00
Nayan Hajratwala
3c5113f3da Fix documentation typos 
Signed-off-by: Nayan Hajratwala <nayan@chikli.com>

Resolves #3110
 2025-04-28 12:55:54 +02:00
Nayan Hajratwala
96eb4eed3f fix typo 
Signed-off-by: Nayan Hajratwala <nayan@chikli.com>
 2025-04-28 12:55:40 +02:00
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