Commit Graph

3397 Commits

Author SHA1 Message Date
buildmaster
2b268196e5 Update SNAPSHOT to 3.2.4 2022-05-27 13:09:25 -04:00
Spencer Gibb
3d03f83847 don't upload docs to maven central 2022-05-26 12:05:35 -04:00
Oleg Zhurakousky
12189ba65e Fix Rabbit test to ensure java17 build
Unfortunately we have to remove one assertion since it gets in the way of module system with reflection
2022-05-24 19:37:40 +02:00
Chris Bono
672f2bcebd Discard raw/wildcard serde matches for KafkaStreams type inference (#2405) 2022-05-24 08:38:23 -05:00
spencergibb
483ffb68a7 Removes java 9+ methods and syntax 2022-05-23 16:29:43 -04:00
Soby Chacko
8ab9e37c9a StreamBridge binder name related changes
An internal helper method used by StreamBridge for resolving the
binder target type to attach the target binder protocol, does not
take into account the binder name when resolving the binder configuration.
Fixing this issue.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2379
Resolves #2401
2022-05-17 19:29:35 +02:00
Chris Bono
19b867cbf5 Cleanup SerdeResolverUtils
* Refactor SerdeResolverUtils logic
* Add more tests in SerdeResolverUtilsTests
* Fixed some random test warnings

Fixes #2370

Code review feedback: remove FQ ref to inner method

Fix checkstyles
2022-05-13 16:26:44 -04:00
Soby Chacko
a827177ac1 Binding name as a consumer/producer property
Make binding names available through Consumer/Producer properties.
Currently, the binders use a ThreadLocal to store the binding name for internal use.
These changes introduce the binding name as a property for both producer/consumer bindings.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2380
2022-05-10 18:27:32 -04:00
Soby Chacko
ed58620a04 Kafka binder docs cleanup
SeekToCurrentBatchErrorHandler is deprecated.
Removing docs references for this with the new DefaultErrorHandler.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2369
2022-05-04 10:58:40 -04:00
Chris Bono
0c698f921e Consider generics when resolving Serdes for KafkaStreams binder (backport)
Fixes #2318
2022-05-03 14:53:23 -05:00
Artem Bilan
3ecbfc6c59 Fix Poller Config for ambiguity
Related to https://stackoverflow.com/questions/72023445/spring-cloud-stream-mutually-exclusive-property-issue

The `PollerConfigEnvironmentPostProcessor` has a flaw not checking user-provided properties
and does not check for mutually exclusive before setting default

* Fix `PollerConfigEnvironmentPostProcessor` to check for other mutual poller
properties before setting default for `fixed-delay`
* Same for `max-messages-per-poll`
* Verify that fix is working in the `PollableSourceTests` where poller
options make sense in the Spring Cloud Stream scenario

* Fix `PollerConfigEnvironmentPostProcessor` for redundant check
* Add more tests into `PollableSourceTests` to verify different
poller properties and their exclusive mutuality
2022-05-02 16:12:19 -04:00
buildmaster
1c78f65c74 Bumping versions 2022-04-29 13:44:51 +00:00
Oleg Zhurakousky
2600178045 Fix documentation and bump versions of snapshots 2022-04-29 11:31:52 +02:00
buildmaster
538a6b4253 Bumping versions 2022-04-27 13:45:19 +00:00
buildmaster
1b76157bf9 Bumping versions to 3.2.4-SNAPSHOT after release 2022-04-27 10:22:05 +00:00
buildmaster
47b43edfa3 Going back to snapshots 2022-04-27 10:22:03 +00:00
buildmaster
5264b1b32f Update SNAPSHOT to 3.2.3 2022-04-27 10:19:08 +00:00
Olga Maciaszek-Sharma
a8962b0206 Revert "Update SNAPSHOT to 3.2.3"
This reverts commit 5c698b8b1b.
2022-04-27 10:56:23 +02:00
Olga Maciaszek-Sharma
478861e5c2 Revert "Going back to snapshots"
This reverts commit 07c683d02a.
2022-04-27 10:56:20 +02:00
Olga Maciaszek-Sharma
f6f9ae8830 Revert "Bumping versions to 3.2.4-SNAPSHOT after release"
This reverts commit f4ead8d7c7.
2022-04-27 10:56:16 +02:00
buildmaster
f4ead8d7c7 Bumping versions to 3.2.4-SNAPSHOT after release 2022-04-26 15:34:13 +00:00
buildmaster
07c683d02a Going back to snapshots 2022-04-26 15:34:12 +00:00
buildmaster
5c698b8b1b Update SNAPSHOT to 3.2.3 2022-04-26 15:31:19 +00:00
Olga Maciaszek-Sharma
68291bf6be Temporarily ignore test failing on Jenkins. 2022-04-26 14:25:12 +02:00
Olga Maciaszek-Sharma
28bb5aa9a2 Fix spring kafka version pom (#2364) 2022-04-26 13:31:18 +02:00
Olga Maciaszek-Sharma
34d1d040cc Upgrade spring-kafka to 2.8.5. (#2363) 2022-04-26 13:01:28 +02:00
Chris Bono
8401447dd5 Use testcontainers for Rabbit binder integration tests
Backport #2341
Resolves #2361
2022-04-26 10:51:08 +02:00
Oleg Zhurakousky
9830dcd7ea polishing 2022-04-26 10:32:20 +02:00
Oleg Zhurakousky
4dae3d0324 GH-SCF_856 Fix propper Cloud Event header prefix in StreamBridge 2022-04-26 10:17:43 +02:00
Oleg Zhurakousky
22ce73fd21 GH-2360 Fix trimmimg in multiple function definition
remove leftovers from spring.cloud.streamfunction.definition

Resolves #2360
2022-04-22 15:32:53 +02:00
Oleg Zhurakousky
7fc2b00ce1 GH-2340 Fix CCE in extended properties
Resolves #2340
2022-04-22 15:16:32 +02:00
Ryan Baxter
ede9cccfee Moving to spring-cloud-build snapshots 2022-04-21 16:31:33 -04:00
Oleg Zhurakousky
12fb253748 Remove old annotation tests 2022-04-21 20:17:37 +02:00
Lars Bilger
b88d34db93 KafkaBinderMetrics Improvements
- Calculate Kafka lag metric correctly even if there are no committed offsets for the group
 - Update authors and copyright years
 - Checkstyle fixes
2022-04-20 12:41:34 -04:00
Soby Chacko
2cf0bd0040 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:44:48 -04:00
Soby Chacko
dd14d24e4f Pin to Spring Kafka snapshot 2022-03-31 15:31:37 -04:00
spencergibb
7a8fe391c9 Fixes parent 2022-03-31 14:32:31 -04:00
spencergibb
36b586c569 adds relative path 2022-03-31 14:30:52 -04:00
spencergibb
330b296721 Updates mvnw to include milestone release check 2022-03-31 14:18:44 -04:00
spencergibb
258baaac52 Fixes dependency management now that stream is a monorepo 2022-03-31 14:18:09 -04:00
spencergibb
2ff7c56cf5 Moves versions to use project.version now that it is a monorepo 2022-03-31 14:14:09 -04:00
Soby Chacko
5b5487de4a Generated docs 2022-03-30 16:13:28 -04:00
spencergibb
45d5ecf5ff Moves core/docs to root of project for compatibility
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2312
2022-03-30 16:08:26 -04:00
Soby Chacko
2c3c1c6483 Docs restructuring changes 2022-03-30 15:56:24 -04:00
spencergibb
92861bcd08 formatting 2022-03-30 15:40:54 -04:00
Christian Tzolov
1995468ab4 Add connectionFactory getter
Resolves #2314
2022-03-30 12:10:39 -04:00
Soby Chacko
ad0da71ea9 Temporarily ignoring sporadically failing tests 2022-03-28 16:52:33 -04:00
Soby Chacko
d459a2f42c Adding build scripts 2022-03-28 15:04:55 -04:00
Soby Chacko
718171dd61 Temporary changes for 3.2.x mono repo 2022-03-28 15:02:28 -04:00
Soby Chacko
48bce0e605 Restructuring maven modules 2022-03-28 13:37:28 -04:00