* 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
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
- Add Micrometer GAUGE Meter metrics. Add new counter.meter-type property to select between counter and gauge meter types.
- Add tests and stock-exchange demo application.
- Update counter-consumer README.
Resolves: https://github.com/spring-cloud/stream-applications/issues/69