If kafka truststore and keystore locations are not local files, then they
are converted to org.springframework.core.io.Resource resources, then copied
to local file system. This means that, paths can be defined as HTTP resources too.
Currently, the Kafka binder only supports CLASSPATH based resources. It would be
useful if we can support non-CLASSPATH like resources such as HTTP, so that if an
application uses config server for example to store certificates, then those will
be copied from it's HTTP endpoint to the local filesystem as Resources.
Checkstyle, documentation fixes.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2761
* Added example to identify Kafka error
* removed implementation and added doc links and added bean example
* changed doc link to the official doc
* Added custom message in the down status of the actuator
* Format Schema Registry Server documentation
Use backtick for formatting API operations
* Fix the url of Schema Registry Server in doc
* Fix the artifact of Schema Registry Server in doc
Embeddable artifact name is
`spring-cloud-stream-schema-registry-core` now
* GH-2729: Reactor Kafka Binder SenderResult Support
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2729
Allow configuration of a `FluxMessageChannel` to receive `SenderResult`s.
Add `SenderResultMessageHandler` to consume from that channel.
Remove undocumented `sendResult` header, which has no value without the
sender result correlation metadata.
* Add integration test and polish property docs.
- result channel must be FMC for reactive binder.
* Add documentation.
* Remove SenderResultMessageHandler.
* Kafka binder partitioning doc improvements
* Update docs/src/main/asciidoc/kafka/kafka_partitions.adoc
Co-authored-by: Gary Russell <grussell@vmware.com>
* Update docs/src/main/asciidoc/kafka/kafka_partitions.adoc
Co-authored-by: Gary Russell <grussell@vmware.com>
* Update docs/src/main/asciidoc/kafka/kafka_partitions.adoc
Co-authored-by: Gary Russell <grussell@vmware.com>
---------
Co-authored-by: Gary Russell <grussell@vmware.com>
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2706
- Update partition count changes in Kafka dynamically during runtime
- Checkstyle fixes
- PartitionHandler changes
- Improved handling of expression with 'payload' in the logic
- Removed getter/setter for PartitionHandler and use ReflectionUtils within Test
- Renamed property to 'dynamicPartitionUpdatesEnabled' and improved documentation (also one line per sentence)
- Improved/renamed test to use embeddedkafka and really test update behaviour
- Javadoc
* Event type routing and deserialization issues
In Kafka Streams binder, deserialization exception handler
does not take effect when event type routing is enabled.
Fixing this issue by allowing the applications to use the
configured or inferred Serde rather than the byte[] Serde
used by the event type router initially.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2613
* Addressing PR review
