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

3486 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Artem Bilan
d351afe27a GH-2311: Migrate AWS Kinesis binder to core 
Fixes https://github.com/spring-cloud/spring-cloud-stream/issues/2311

* Use Tescontainers for Localstack
* Fix tests according new `core` status quo
* Improve `KinesisStreamProvisioner` to wait for stream become active
before moving on to other logic

Disable Kinesis binder LocalstackContainerTest on mac
 2022-04-01 16:30:53 -04:00
buildmaster
bf02424d27 Bumping versions 2022-04-01 17:27:39 +00:00
Soby Chacko
b4c6ec8332 Concurrency property issues in KStream binder 
In Kafka Streams binder, when using a function with camelcase names,
it causes issues for parsing binding level concurrency properties.

Fixing this issue.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2316
 2022-03-31 16:43:17 -04:00
buildmaster
85ffd4d92d Going back to snapshots 2022-03-31 20:05:34 +00:00
buildmaster
a9bd88acce Update SNAPSHOT to 4.0.0-M2 2022-03-31 20:02:59 +00:00
spencergibb
a4d6b2e7a7 disables test 2022-03-31 15:47:39 -04:00
Oleg Zhurakousky
0ff2a4ad6a Remove dependency on old test module 2022-03-31 21:27:45 +02:00
spencergibb
a951837e4e Fixes parent 2022-03-31 14:26:00 -04:00
spencergibb
a7a2b8943c adds relative path 2022-03-31 14:19:43 -04:00
spencergibb
2b053c71b7 Updates mvnw to include milestone release check 2022-03-31 14:07:41 -04:00
spencergibb
158e4b22cf Fixes dependency management now that stream is a monorepo 2022-03-31 14:00:09 -04:00
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