Fixes https://github.com/spring-projects/spring-integration/issues/3226
* Redis stream message handler support.
* This is the outbound part publishing message to the actual stream using ReactiveStreamOperations
* Addition of more test cases with one using `MessageChannel`.
* Improvements after PR review.
* Removed failed test reading List from a Stream
* Code style clean up
* Remove `rawtypes` usage
* Remove redundant inner classes for test model
* Add `What's New` note
s/Enhancement Proposal/Extension Protocol/
XMPP XEPs are extension protocols of XMPP "core" (i.e., RFC 6120 and
RFC 6121).
See also https://xmpp.org/extensions/xep-0001.html:
"The focal point of the process is a series of protocol specifications
called XMPP Extension Protocols or XEPs."
- merge master branch from old repo (`git-filter-repo`) for src branch
- update build.gradle
- copy docs from Spring for Apache Kafka Chapter
Doc polishing.
Fix http: references in tests.
* Add `What's New` note and fix `polling-consumer.adoc`
not linking to external project any more
* Rename schema
* Upgrade to Gradle 6.3-rc-3 for transitive dependency fix.
* Remove version from schema; polish `build.gradle` to remove unneeded features.
* Added support for header-mapper to outbound-channel-adapter and
outbound-gateway XML
* Follow up on review
* Corrected mistake
* Corrected indentation
Fixes https://github.com/spring-projects/spring-integration-kafka/issues/280
* Refactored to topics/topicPattern to be a property to
prevent constructor telescoping
* Add support for manual partition assignment
- Cleanup after rebasing from #283
- Add additional tests
* Fix checkstyle
* Remove redundant factory methods
* Add better test for static assignment
* Use ConsumerProperties
Fix typo where ContainerProperties was used
instead of ConsumerProperties
* Simplify construction
* Remove unused import
* Use ObjectUtils
* Use component name for clientId
* Collapse static assignment for loop
* Fix lint warning
Starting with version `3.0.x`, the `KafkaInboundGateway` and
`KafkaMessageDrivenChannelAdapter` rely on the
`RetryContext.getRetryCount()` for the
`IntegrationMessageHeaderAccessor.DELIVERY_ATTEMPT` message header, but
the `RetryContext` is obtained from the `TheadLocal` `attributesHolder`,
which is populated from the `RetryListener.open()` only if
`recoveryCallback != null`
* Fix `KafkaInboundGateway` and `KafkaMessageDrivenChannelAdapter` to
populate `TheadLocal` `attributesHolder` with the `RetryContext`
from the `RetryListener.open()` when only `retryTemplate != null`
**Cherry-pick to `master` & 3.0.x**
# Conflicts:
# src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java
