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

3442 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
ncheema
ff88e5837f fix assertion order 2022-02-16 10:11:11 +01:00
ncheema
9bd602085b cleanup test 2022-02-16 10:11:11 +01:00
ncheema
30429097a9 check for null producer properties 2022-02-16 10:11:11 +01:00
Oleg Zhurakousky
7c5c0c34c3 GH-2282 Ensure BeanPostProcessors do not triger early initialization 
Also, removed dead references and comments to legacy post processors
Resolves #2282
 2022-02-16 10:08:37 +01:00
Soby Chacko
e848ec8051 Remove call to deprecated method in Spring Kafka 2022-02-15 11:42:46 -05:00
Marcus Kempe
5c62dd6b55 Language improvement spring-cloud-stream docs 
Improved language in the Bindings chapter.
 2022-02-08 10:52:39 +01:00
Gary Russell
c472b185be 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 10:49:19 -05:00
Soby Chacko
001d79cf10 4.0 related cleanup 
- Remove InternalPropertyNames class
- Cleanup in AbstractBindableProxyFactory
 2022-02-02 16:05:28 -05:00
Oleg Zhurakousky
b692bffd62 Additional cleanup and simplification 2022-02-02 17:30:45 +01:00
Oleg Zhurakousky
a232523f51 Remove dead classes 2022-02-02 16:59:10 +01:00
Oleg Zhurakousky
cf87bb8149 Remove deleted-test directory 2022-02-02 15:28:40 +01:00
Oleg Zhurakousky
8c3fdda33e Re-enable CustomPartitionedProducerTest 2022-02-02 15:22:22 +01:00
Oleg Zhurakousky
ac8c7f9529 Re-enable ErrorHandlingTests & BindingServiceTests 2022-02-02 15:01:00 +01:00
Oleg Zhurakousky
0fd268ff02 Address .todo tests commented as a result of removal of annotation configuration 
Fix ErrorHandlingTests

Remove stub binders from tests

remove dead test classes
 2022-02-02 12:03:54 +01:00
Soby Chacko
dc17fcdfec Cleaning up BindableProxyFactory 2022-02-01 18:56:27 -05:00
Oleg Zhurakousky
c5fd0be874 GH-2272 Register JavaTimeModule with BindingsLifecycleController's ObjectMapper 
Resolves #2272
 2022-02-01 18:38:08 +01:00
Adam Benjamin
1e4f5829fe GH-317: Add Static Routing Key 
Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/317

GH-317 Adding static routing key field to producer properties

GH-317 Updating based on PR comments

GH-317 Updating import order based on checkstyle

GH-317 Updating import order based on checkstyle
 2022-02-01 10:41:41 -05:00
Soby Chacko
235146e29a Revert "Revert "Update documented version of kafka-clients"" 
This reverts commit 65960e101f.
 2022-01-27 10:53:54 -05:00
Soby Chacko
8eecf03827 Revert "Revert "Update Kafka client version to 3.1.0"" 
This reverts commit 01dbb49313.
 2022-01-27 10:53:27 -05:00
Soby Chacko
3f1f7dbbe8 Revert "Revert "Fixed invalid java code snippet"" 
This reverts commit d2c12873d0.
 2022-01-27 10:52:22 -05:00
Oleg Zhurakousky
e9734bfd5d Update pom.xml 2022-01-27 16:45:51 +01:00
Oleg Zhurakousky
8b845ae898 Update pom.xml 2022-01-27 16:45:28 +01:00
Oleg Zhurakousky
4db0286452 Update pom.xml 2022-01-27 16:44:59 +01:00
buildmaster
45245f4b92 Going back to snapshots 2022-01-27 15:39:18 +00:00
buildmaster
9922922036 Update SNAPSHOT to 4.0.0-M1 2022-01-27 15:37:22 +00:00
Oleg Zhurakousky
eee7e63876 Revert "Disable test temp" 
This reverts commit 1af1654a15.
 2022-01-27 16:26:52 +01:00
Oleg Zhurakousky
c3b6610c9f Update SK and SIK version 2022-01-27 16:24:05 +01:00
Oleg Zhurakousky
d2c12873d0 Revert "Fixed invalid java code snippet" 
This reverts commit 4cbcb4049b.
 2022-01-27 16:16:26 +01:00
Oleg Zhurakousky
01dbb49313 Revert "Update Kafka client version to 3.1.0" 
This reverts commit a25e2ea0b3.
 2022-01-27 16:16:10 +01:00
Oleg Zhurakousky
65960e101f Revert "Update documented version of kafka-clients" 
This reverts commit 69e377e13b.
 2022-01-27 16:16:02 +01:00
buildmaster
e1e361392b Going back to snapshots 2022-01-27 14:57:45 +00:00
buildmaster
ec5bb4412c Update SNAPSHOT to 4.0.0-M1 2022-01-27 14:56:10 +00:00
buildmaster
333017b8b7 Going back to snapshots 2022-01-27 14:55:34 +00:00