Move KStream binder to the main kafka binder repo #144
Assignees
Milestone
Comments
sobychacko
changed the title
Closed
sobychacko
added a commit
to sobychacko/spring-cloud-stream-binder-kafka
that referenced
this issue
Jul 21, 2017
Adding integration tests Fix spring-cloud#144
Closed
sobychacko
added a commit
to sobychacko/spring-cloud-stream-binder-kafka
that referenced
this issue
Sep 20, 2017
Fix spring-cloud#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
artembilan
pushed a commit
that referenced
this issue
Sep 29, 2017
fixes #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#913 Fixes #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 Fix #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: spring-cloud/spring-cloud-stream#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 #62 No longer needed. GH-169: Use the Actual Partition Count (Producer) Fixes #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
sobychacko
added a commit
to sobychacko/spring-cloud-stream-binder-kafka
that referenced
this issue
Oct 5, 2017
fixes spring-cloud#193 Integration missed commits and provide some polishing, improvements and fixes Remove `resetOffsets` option Fix spring-cloud#170 Use parent version for spring-cloud-build-tools Add update version script Fixes for consumer and producer property propagation Fix spring-cloud#142 spring-cloud#129 spring-cloud#156 spring-cloud#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-spring-cloudGH-913: Error Handling via ErrorChannel Relates to spring-cloud/spring-cloud-stream#913 Fixes spring-cloud#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 :) spring-cloudGH-144: Add Kafka Streams Binder Fix spring-cloud#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 spring-cloud#160 * Addressing PR review comments * Addressing PR review comments * Addressing PR review comments Fixes spring-cloud#181 SCSt-spring-cloudGH-916: Configure Producer Error Channel Requires: spring-cloud/spring-cloud-stream#1039 Publish send failures to the error channel. Add docs Revert to Spring Kafka 1.1.6 spring-cloudGH-62: Remove Tuple Kryo Registrar Wrapper Resolves spring-cloud#62 No longer needed. spring-cloudGH-169: Use the Actual Partition Count (Producer) Fixes spring-cloud#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 spring-cloudGH-188: KStream Binder Properties KStream binder: support class for application level properties Provide commonly used KStream application properties for convenient access at runtime Fix spring-cloud#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 spring-cloud#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 spring-cloud#199 Addressing PR review comments Addressing PR review comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
A fully working version of the kstream binder is here: https://github.com/mbogoevici/spring-cloud-stream-binder-kstream
This issue is for moving it to the main repo.
The text was updated successfully, but these errors were encountered: