fixes spring-cloud/spring-cloud-stream-binder-kafka#193
Integration missed commits and provide some polishing, improvements and fixes
Remove `resetOffsets` option
Fix#170
Use parent version for spring-cloud-build-tools
Add update version script
Fixes for consumer and producer property propagation
Fix#142#129#156#162
- Remove conditional configuration for Boot 1.4 support
- Filter properties before creating consumer and producer property sets
- Restore `configuration` as Map<String,String> for fixing Boot binding
- Remove 0.9 tests
SCSt-GH-913: Error Handling via ErrorChannel
Relates to spring-cloud/spring-cloud-stream#913Fixes#162
- configure an ErrorMessageSendingRecoverer to send errors to an error channel, whether or not retry is enabled.
Change Test Binder to use a Fully Wired Integration Context
- logging handler subscribed to errorChannel
Rebase; revert s-k to 1.1.x, Kafka to 0.10.1.1
Remove dependency overrides.
POM structure corrections
- move all intra-project deps to dependency management
- remove redundant overrides of Spring Integration Kafka
Remove reference to deleted module
- `spring-cloud-stream-binder-kafka-test-support` was previously
removed, but it was still added as an unused dependency to the
project
Remove duplicate debug statement.
unless you really really want to make sure users see this :)
GH-144: Add Kafka Streams Binder
Fixspring-cloud/spring-cloud-stream-binder-kafka#144
Addressing some PR reviews
Remove java 8 lambada expressions from KStreamBoundElementFactory
Initial - add support for serdes per binding
Fixing checkstyle issues
test source 1.8
Convert integration tests to use Java 7
Internal refactoring
Remove payload serde code in KStreamBoundElementFactory and reuse it from core
Addressing PR comments
cleanup around payload deserialization
Update to latest serialization logic
Extract common properites class for KStream producer/consumer
Addressing PR review comments
* Remove redundant dependencies for KStream Binder
Documentation for KStream binder
* Documentation for KStream binder
Fix#160
* Addressing PR review comments
* Addressing PR review comments
* Addressing PR review comments
Fixes#181
SCSt-GH-916: Configure Producer Error Channel
Requires: https://github.com/spring-cloud/spring-cloud-stream/pull/1039
Publish send failures to the error channel.
Add docs
Revert to Spring Kafka 1.1.6
GH-62: Remove Tuple Kryo Registrar Wrapper
Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/62
No longer needed.
GH-169: Use the Actual Partition Count (Producer)
Fixes https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/169
If the configured `partitionCount` is less than the physical partition count on an existing
topic, the binder emits this message:
The `partitionCount` of the producer for topic partJ.0 is 3, smaller than the actual partition count of 8 of the topic.
The larger number will be used instead.
However, that is not true; the configured partition count is used.
Override the configured partition count with the actual partition count.
0.11 Binder
Initial Commit
- Transactional Binder
Version Updates
- Headers support
KStreams and 0.11
GH-188: KStream Binder Properties
KStream binder: support class for application level properties
Provide commonly used KStream application properties for convenient access at runtime
Fix#188
Since windowing operations are common in KStream applications, making the TimeWindows object
avaiable as a first class bean (using auto configuration). This bean is only created if the
relevant properties are provided by the user.
Kstream binder: producer default Serde changes
Change the way the default Serde classes are selected for key and value
in producer when only one of those is provided by the user.
Fix#190
KStream binder cleanup,
merge cleanup
re-update kafka version
2.0 related changes
Fix tests
Upgrade Kstream tests
converting anonymous classes to lambda expressions
Renaming Kafka-11 qualifier from test module
Refactoring test class names
cleanup
adding .jdk8 files
Fix KafkaBinderMetrics in 2.0
Fix#199
Addressing PR review comments
Addressing PR review comments
