SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,475 Commits 28 Branches 0 Tags
c6b6d620e2e8cb23cdd21ab49fdf95e708b6ed62
Commit Graph

3475 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
spencergibb
c6b6d620e2 Moves versions to use project.version now that it is a monorepo 2022-03-31 13:33:20 -04:00
spencergibb
6b9f6a5163 Moves core/docs to root of project for compatibility 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2312
 2022-03-30 16:05:21 -04:00
spencergibb
ee50d722a5 formatting 2022-03-30 12:44:56 -04:00
Christian Tzolov
d57b445a62 Add connectionFactory getter 
Resolves #2314
 2022-03-30 12:09:34 -04:00
Oleg Zhurakousky
f58dcf371d Fix concurrency issue in StreamBridge 
Resolves #2300
 2022-03-25 14:26:32 +01:00
Sébastien NUSSBAUMER
9f28bcde3d GH-2299 Add test to ensure scst_partition header is always set in concurrent scenarios 2022-03-25 12:03:26 +01:00
Gary Russell
8a8a440c73 GH-2307: Fix Problems with Rabbit Declarables 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2307

- when creating `Declarables` beans for redeclaration after a connetion failure
  2 DLX/DLQ bindings used the same bean name so the second one was never recovered/
- removing consumer `Declarable` beans from the `autoDeclareContext` was incomplete
- removing producer `Declarable` beans was not performed at all

- fix bean names; fix cleanup; add tests for all config scenarios
- check cleanup in all `RabbitBinderTests`

**cherry-pick to 3.2.x when the mono repo is established**
Resolves #2309
 2022-03-25 11:21:55 +01:00
Oleg Zhurakousky
1edf4db14e GH-2303 Performance improvements 
Most of the work is done in s-c-function though, so here it is very light

Resolves #2303
 2022-03-22 13:56:03 +01:00
Oleg Zhurakousky
95ea69f9ac Perf improvement on StreamBridge 2022-03-22 10:05:01 +01:00
Oleg Zhurakousky
bf8b963488 Make s-c-function deployer optioinal dependency in rabbit binder 2022-03-21 18:09:14 +01:00
Soby Chacko
37028f0c90 GH-2302: Remove metrics related components 
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2302
 2022-03-16 12:02:29 -04:00
Oleg Zhurakousky
17e21cc456 GH-2280 Updated polling documentation 
Resolves #2280
 2022-03-16 15:00:38 +01:00
Oleg Zhurakousky
3e9fc5152e GH-2280 Add initial support for per-binding poller configuration 2022-03-16 14:38:33 +01:00
Oleg Zhurakousky
972a0ef35a GH-2305 Remove remaning legacy test modules 
spring-cloud-stream-integration-tests
spring-cloud-stream-test-support-internal

Resolves #2305
 2022-03-16 11:30:27 +01:00
Oleg Zhurakousky
c857339e46 GH-2304 Remove old test support binder 
Resolves #2304
 2022-03-16 10:30:10 +01:00
Soby Chacko
840933d164 JUnit 5 migration for Kafka Streams binder tests 2022-03-15 18:45:05 -04:00
Gary Russell
6d8be51437 GH-2293: MessageConverter Bean Name 
Add test to consume full `ReceiverRecord`.

Resolves #2295
 2022-03-15 13:09:45 +01:00
Gary Russell
9ccf9ce48b GH-2293: Cancel Subscription on Stop 2022-03-12 13:16:40 -05:00
Soby Chacko
9b8ebe235e JUnit 5 migration for more Kafka binder tests 2022-03-11 16:50:54 -05:00
Soby Chacko
e51ade49db Kafka binder tests migration to JUnit 5 2022-03-11 15:07:37 -05:00
Soby Chacko
1c4f5e24dc Initial JUnit 5 migration for Kafka binder 2022-03-11 13:38:18 -05:00
Soby Chacko
dedc79d92b Tests cleanup 2022-03-11 12:56:32 -05:00
Soby Chacko
dcaa621b3c JUnit 5 migration for core tests 2022-03-11 12:27:47 -05:00
Soby Chacko
0f213fedf6 Migrating to JUnit 5 tests 
Migrating a few unit tests in core to JUnit 5
 2022-03-11 11:30:32 -05:00
Oleg Zhurakousky
56bb512e6e GH-2292 Update documentation explaining reactive/imparative composition 
Resolves #2292
 2022-03-11 17:27:28 +01:00
Gary Russell
f3ccc7b72d GH-2293: Initial Commit Reactor-Kafka Binder 
Note that it requires the message channel to be a `FluxMessageChannel`.

It currently only supports `Consumer<ReceiverRecord<?, ?>>` (no conversion).

The function binding should use the message channel directly instead of bridging
the direct channel to a reactive channel.

Producer Side PoC

Binder specific changes in ReactorKafkaBinder

Binder configuration

More changes to the reactive binder

Move KafkaBinderEnvironmentPostProcessor to the core module

Change binder key in spring.binders

Adding an e2e IT test for the reactive binder

Add lifecycle to integration adapters.

Remove unnecessary doStop().

Fix import order.
 2022-03-10 17:22:20 -05:00
Soby Chacko
2f6de9263e Removed ununsed old release scripts 2022-03-09 13:36:32 -05:00
Hasan Kara
40a81e01be GH 2290 Fix wrong image URL 2022-03-09 10:02:01 -05:00
Soby Chacko
24035bad16 More README cleanup 2022-03-08 17:29:36 -05:00
Soby Chacko
3d85739251 README cleanup 2022-03-08 17:24:23 -05:00
Soby Chacko
5ddf93bd6d Version updates 
Spring kafka - 3.0.0-SNAPSHOT
Kafka client - 3.1.0

Remove the temporarry changes to micrometer dependency version
 2022-03-08 10:48:46 -05:00
Soby Chacko
21999e2660 Build cleanup 2022-03-07 18:17:41 -05:00
Soby Chacko
a6f237b79c cleanup 2022-03-07 17:43:13 -05:00
Soby Chacko
6c8423365a Simple parent pom with modules. 
Shell scripts for building core, kafka binder, rabbit binder
and bom (dependencies) modules individually.
 2022-03-07 17:23:58 -05:00
Soby Chacko
9fb42b65d9 Changing the micrometer version in Kafka binder 
Temporarily changing this to match with Spring-Kafka's.
 2022-03-07 11:34:12 -05:00
Oleg Zhurakousky
09a33c7731 Polish 2022-03-07 14:30:34 +01:00
Soby Chacko
e1232ae731 Restructuring the repository 2022-02-23 19:42:29 -05:00
Soby Chacko
3e8668765a Merge remote-tracking branch 'bom/monorepo-poc' into monorepo-poc 2022-02-23 15:46:53 -05:00
Soby Chacko
d6e5fc8124 Migrating to mono repo 2022-02-23 15:45:28 -05:00
Soby Chacko
585f77e589 Relocate both Kafka and Rabbit binders within core 2022-02-23 15:41:13 -05:00
Soby Chacko
dd31d8522c Merge remote-tracking branch 'rabbit-binder/monorepo-poc' into monorepo-poc 2022-02-23 15:35:23 -05:00
Soby Chacko
5c416ef3a9 Migrating to mono-repo 2022-02-23 15:33:21 -05:00
Soby Chacko
23fc6004fa Merge remote-tracking branch 'kafka-binder/monorepo-poc' into monorepo-poc 2022-02-23 15:24:15 -05:00
Soby Chacko
16b1f80673 Migrating to mono-repo 2022-02-23 15:18:12 -05:00
Gary Russell
56ab5498b1 Doc for producerType property 
Missing property from docs.
 2022-02-23 10:15:44 -05:00
Soby Chacko
3045019398 Version downgrades 
Temporily downgrade SK to 3.0.0-M1 and Kafka client to 3.0.0
 2022-02-22 17:47:26 -05:00
Oleg Zhurakousky
d8ed65a249 Polishing 
Resolves #2284

Polishing
 2022-02-18 12:10:24 +01:00
Soby Chacko
669b820f98 Initial commit for reactive binding support 
*  New binding target factory for FluxMessageChannel
 *  Introduce a new property to activate reactive binding -- spring.cloud.stream.reactive
 *  Refactoring BindableFunctionProxyFactory for FluxMessageChannel target binding
 *  Similar refactoring in FunctionConfiguration
 *  Test to verify FluxMessageChannel binding

Addressing PR review comments

Addressing PR review comments

Addressing PR review comments.

Allow reactor and MC based binders co-exist in an application
in order to support multiple functions use different binders
(with different target types).

Addressing PR review comments.
 2022-02-18 11:56:12 +01:00
Soby Chacko
7a9aab03a4 Addressing Rabbit Binder Health Indicator Issues 
Currently, using the property management.health.binders.enabled,
we cannot disable the Rabbit health indicator. Addressing this issue.

Adding docs.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/341
 2022-02-16 13:20:39 +01:00
Oleg Zhurakousky
8eb241ca55 GH-2275 Fix checkstyle violations 
Resolves #2275
 2022-02-16 10:22:52 +01:00