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
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
