* This RSocket consumer is using the fire-and-forget strategy of execution.
* Generating the corresponding sink.
* Addressing the original PR review comments from
https://github.com/spring-cloud/stream-applications/pull/116
* Addressing PR review comments
* Fix README
* Addressing PR review
It turns out that endpoint for S3 Source is starting to
consume the `Flux` earlier than an actual subscription
happens for the whole flow downstream
* Introduce a `MonoProcessor<Subscription> downstreamSubscription`
to fulfill from the downstream subscription and handle from the
`delaySubscription()` on the `Flux` for source data
* Add metadata.store.type Property and idempotent SftpSupplier for list-only
* Implement list-only for S3 source and Optimize metadastore access
* Fixed build and READMEs
* Change to ConditionalOnProperty
* Change to ReactiveMessageProducer
* Update cdc-debezium-source/README.adoc
* Make all MetadataStoreProperties visible
* GH-110: Fix filter function for emitting `null`
Fixes https://github.com/spring-cloud/stream-applications/issues/110
Turns out when functions are composed in the Spring Cloud Stream environment,
they are called via reactive wrappers which don't allow to emit `null` from the
`map()` operator.
* Make `filterFunction` fully reactive to reply on the `Flux.filter()` operator
* Add `config-common` for auto-conversion string configuration options into `Expression` instances
* Add `spring-boot-starter-json` dependency since it is required by the `SpelExpressionConverterConfiguration`
* Add `reactor-test` dependency to test the final solution
* Remove redundant dependencies from the `filter-processor`
* * Add `proxyBeanMethods = false` into `FilterFunctionConfiguration`
* Fix default expression to `true` instead of `payload`, which does not fit to filter logic
* Fix JavaDoc for `expression` property
* Remove redundant `application.properties` from the `filter-function`
* Have all the required dependencies in class path which give us a `MessageGroupStore` implementation
* Disable all their auto-configurations in the `ExcludeStoresAutoConfigurationEnvironmentPostProcessor`
* Enable only those which are configured by the `aggregator.messageStoreType` property
* Implement a fully reactive function around an aggregator making an interaction via a pair of `FluxMessageChannel`
* Fix checkstyle issues
* Change the app generator maven plugin to new coordinates
Fixes https://github.com/spring-cloud/stream-applications/issues/103
Excludes `splitter-function` from dependencies.
There may be some other sources that have the same issue.
Also, includes changes to handle function composition with , or `|` delimiter
- Add supplier, source and boot auto-config.
- Add work around for KafkaNull handling.
- Update CDC to 1.2.1.Final. Replace the deprecated properties.
remove comments
Add missing metadata configuration. Improve README docs.
CDC: add all metadata for doc auto-generation
Remove custom KafkaNullConverter.
- The fixed KafkaNullConverter implementation comes with kafka binder 3.0.8-BUILD-SNAPSHOT or newer.
Add repositories to maven config in app generation project.
Remove the unnecessary function version in maven plugin configuration for app generation.
This might be a temporory solution to address some issues on the CI envrionment.
We will most likely remove the changes from this commit later on once the CI
issues are addressed
