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

4279 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Soby Chacko
e5d0d14836 Remove reactive-kafka binder 
Since the reactor-kafka project has been discontined, we are removing
reactive Kafka binder from Spring Cloud Stream which was already
deprecated on the 4.3.x line.

See: https://spring.io/blog/2025/05/20/reactor-kafka-discontinued

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-06-12 11:33:06 -04:00
spring-builds
0a3e24322e Bumping versions 2025-06-12 14:17:10 +00:00
Oleg Zhurakousky
9cd63156a1 Disable flaky Kafka tests 
Signed-off-by: Oleg Zhurakousky <ozhurakousky@vmware.com>
 2025-06-12 07:05:43 -04:00
Soby Chacko
3a937debfa Kafka binders test migration to Kafka 4.0.0 client 
- Replace deprecated ValueTransformerWithKey with FixedKeyProcessor
- Update TimeWindows.of() to TimeWindows.ofSizeWithNoGrace()
- Migrate branch() to split().branch() with Named and Branched
- Replace deprecated KafkaTestUtils.consumerProps() signature
- Update StreamPartitioner return type to Optional<Set<Integer>>
- Modernize Processor API imports and method signatures
- Add EmbeddedKafkaBroker parameter injection for JUnit 5
- Fix Consumer.poll() to use Duration parameter
- Remove unused imports and deprecated API usage

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
 2025-06-11 20:18:49 -04:00
Soby Chacko
4d4e64b415 Revert "Initial/partial Kafka migration" 
This reverts commit 767fc86dfb.
 2025-06-11 14:21:14 -04:00
Oleg Zhurakousky
767fc86dfb Initial/partial Kafka migration 2025-06-11 10:56:33 -04:00
Oleg Zhurakousky
af820ee3c1 Initial 5.0 migration 2025-06-11 10:55:38 -04:00
Mohamed Macow
11594bb37a Correct Contribution section of Readme 
Signed-off-by: Mohamed Macow <58916277+darth-raijin@users.noreply.github.com>

Resolves #3115
 2025-06-02 16:58:21 +02:00
spring-builds
a23dc7fe0a Going back to snapshots 2025-05-29 14:09:51 +00:00
spring-builds
88532ae040 Update SNAPSHOT to 4.3.0 2025-05-29 14:06:48 +00:00
spring-builds
3bde3697ab Bumping dependency versions after release 2025-05-29 00:12:08 +00:00
spring-builds
57c0198979 Bumping versions to 4.3.1-SNAPSHOT after release 2025-05-29 00:10:54 +00:00
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