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

3004 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Soby Chacko
f1ac8f92f1 Merge remote-tracking branch 'r-binder/monorepo-3.2.x' into monorepo-3.2.x 2022-03-28 13:19:16 -04:00
Soby Chacko
2df3888c73 Rabbit binder - mono repo for 3.2.x branch 2022-03-28 13:18:48 -04:00
Soby Chacko
f6d9cbbf47 Merge remote-tracking branch 'k-binder/monorepo-3.2.x' into monorepo-3.2.x 2022-03-28 13:17:26 -04:00
Soby Chacko
03c143ad67 Kafka binder - mono repo for 3.2.x branch 2022-03-28 13:16:31 -04:00
Oleg Zhurakousky
4e66d2b513 Cherry-pick 2309 2022-03-25 11:21:13 +01:00
Oleg Zhurakousky
ac13dd7439 Make s-c-function deployer optional dependency 2022-03-21 18:11:59 +01:00
Oleg Zhurakousky
58a7a74cb4 GH-2280 Add per-binding poller configuration 2022-03-16 15:50:55 +01:00
Oleg Zhurakousky
1d896435c7 GH-2292 Update documentation explaining reactive/imparative composition 
Resolves #2292
 2022-03-11 17:38:03 +01:00
Soby Chacko
090acc408f Kafka Streams binder uncaught exception changes 
The default StreamsUncaughtExceptionHandler is added only if the
application does not provide one.
 2022-03-03 14:38:38 -05:00
Ryan Baxter
72e64b7122 Bumping function release 2022-02-18 10:44:22 -05:00
buildmaster
922f735306 Bumping versions to 3.2.3-SNAPSHOT after release 2022-02-16 18:31:22 +00:00
buildmaster
735958e7ec Going back to snapshots 2022-02-16 18:31:21 +00:00
buildmaster
2851464bd0 Update SNAPSHOT to 3.2.2 2022-02-16 18:29:43 +00:00
buildmaster
38d710a20b Bumping versions to 3.2.3-SNAPSHOT after release 2022-02-16 18:16:18 +00:00
buildmaster
7bfe00519b Going back to snapshots 2022-02-16 18:16:18 +00:00
buildmaster
0e0999f5b1 Update SNAPSHOT to 3.2.2 2022-02-16 18:14:36 +00:00
buildmaster
c00a8e28be Bumping versions to 3.2.3-SNAPSHOT after release 2022-02-16 18:10:47 +00:00
buildmaster
ade24c521b Going back to snapshots 2022-02-16 18:10:46 +00:00
buildmaster
699f2baf5e Update SNAPSHOT to 3.2.2 2022-02-16 18:08:42 +00:00
Soby Chacko
da049fc980 Update Spring Kafka/SIK versions 2022-02-16 10:08:33 -05:00
Soby Chacko
b21e4020a3 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:48:11 +01:00
Oleg Zhurakousky
cf998826b8 GH-2275 Fix checkstyle violations 
Resolves #2275
 2022-02-16 10:41:03 +01:00
ncheema
b50480c2ee fix assertion order 2022-02-16 10:40:58 +01:00
ncheema
bff7631907 cleanup test 2022-02-16 10:40:51 +01:00
ncheema
c1abf65935 check for null producer properties 2022-02-16 10:40:40 +01:00
Oleg Zhurakousky
9ec7cf9b43 GH-2282 Ensure BeanPostProcessors do not triger early initialization 2022-02-16 10:10:37 +01:00
Gary Russell
170166ac57 GH-1195: Fix Pause/Resume Documentation 
Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1195

Remove obsolete documentation.

**cherry-pick to 3.2.x**
 2022-02-07 14:33:45 -05:00
Oleg Zhurakousky
800832d9ac GH-2272 Register JavaTimeModule with BindingsLifecycleController's ObjectMapper 
Resolves #2272
 2022-02-01 16:46:13 +01:00
Rex Ijiekhuamen
5b880a8104 Fixed invalid java code snippet 2022-01-24 10:23:17 -05:00
Soby Chacko
42d3b92c7b Test package changes 2022-01-18 15:52:18 -05:00
Oleg Zhurakousky
909f4af4b4 GH-2265 Fix support for creating explicit bindings 
This commit ensures that in the event there is a Consumer or Supplier the output-bidning or input-binding is still created

Resolves #2265
 2022-01-18 14:07:50 +01:00
Oleg Zhurakousky
2969e14bdc GH-2268 Ensure StreamBridge works with nullChannel 
Resolves #2268
 2022-01-18 11:51:22 +01:00
Mandy Neumann
ede1d0f0f7 Fix some spelling errors 2022-01-18 10:34:40 +01:00
Oleg Zhurakousky
ff281c56c4 GH-2266 Fix channel interceptor application for dynamic destinations 
Resolves #2266
Resolves #2269
 2022-01-18 10:32:12 +01:00
Sébastien NUSSBAUMER
36e93e2c6f GH-2266 Add test to ensure GlobalChannelInterceptor is not added multiple times to the MessageChannels 2022-01-17 08:36:08 +01:00
Oleg Zhurakousky
738b658ae9 GH-2265 Add support for creating explicit bindings 
Resolves #2265
 2022-01-14 15:55:12 +01:00
Soby Chacko
577ffbb67f Enable custom binder health check impelementation 
Currently, KafkaBinderHealthIndicator is not customizable and included by default
when Spring Boot actuator is on the classpath. Fix this by allowing the application
to provide a custom implementation. A new marker interface called KafkaBinderHealth
can be used by the applicaiton to provide a custom HealthIndicator implementation, in
which case, the binder's default implementation will be excluded.

Tests and docs changes.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1180
 2022-01-13 09:56:32 -05:00
Soby Chacko
3770db7844 Retries for HostInfo in InteractiveQueryService 
InteractiveQueryService methods for finding the host info for Kafka Streams
currently throw exceptions if the underlying KafkaStreams are not ready yet.
Introduce a retry mechanism so that the users can control the behaviour of
these methods by providing the following properties.

spring.cloud.stream.kafka.streams.binder.stateStoreRetry.maxAttempts (default 1)
spring.cloud.stream.kafka.streams.binder.stateStoreRetry.backoffPeriod (default 1000 ms).

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1185
 2022-01-11 18:49:23 -05:00
Eduard Domínguez
406e20f19c Fix: KeySerde setup not using expected key type headers 
checkstyle fixes
 2022-01-11 14:37:20 -05:00
Soby Chacko
648188fc6b Event type routing improvements (Kafka Streams) 
When routing by event types, the deserializer omits the
topic and header information. Fixing this issue.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1186
 2022-01-05 19:30:36 -05:00
Eduard Domínguez
63b306d34c GH-1176: KeyValueSerdeResolver improvements 
Use extended properties when initializing Consumer and Producer Serdes.

Updated copyright years and authors.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1176
 2021-12-10 14:02:29 -05:00
Oleg Zhurakousky
a1741794ed GH-2249 Fix partition handling in StreamBridge 
Resolves #2249
 2021-12-08 11:28:49 +01:00
Oleg Zhurakousky
150bffbbb6 GH-2253 Provide isolated ObjectMapper to BindingsLifecycleController 
This is specifically to avoid any potetial interference from the user
Resolves #2253
 2021-12-08 09:31:28 +01:00
Oleg Zhurakousky
954007053f GH-2254 Make healthcheck classes public 
Resolves #2254
 2021-12-07 12:28:17 +01:00
Oleg Zhurakousky
14b37fd059 Revert "Disable tests temporarily" 
This reverts commit da395381e3.
 2021-12-01 18:12:43 +01:00
Oleg Zhurakousky
ad0b9662c9 Update functions 2021-12-01 18:12:27 +01:00
Oleg Zhurakousky
4c58747891 Update functions version 2021-12-01 18:11:36 +01:00
buildmaster
5cd8e06ec6 Bumping versions to 3.2.2-SNAPSHOT after release 2021-12-01 16:58:07 +00:00
buildmaster
79be11c9e9 Going back to snapshots 2021-12-01 16:58:07 +00:00
buildmaster
fc4358ba10 Update SNAPSHOT to 3.2.1 2021-12-01 16:55:37 +00:00