This repository has been archived by the owner on Mar 30, 2023. It is now read-only.
Support topicPattern in KafkaMessageSource #280
Comments
Walliee
changed the title
Walliee
added a commit
to Walliee/spring-integration-kafka
that referenced
this issue
Aug 17, 2019
* Refactored to topics/topicPattern to be a property to prevent constructor telescoping resolves spring-attic#280
Walliee
added a commit
to Walliee/spring-integration-kafka
that referenced
this issue
Aug 25, 2019
* Refactored to topics/topicPattern to be a property to prevent constructor telescoping resolves spring-attic#280
Walliee
added a commit
to Walliee/spring-integration-kafka
that referenced
this issue
Aug 25, 2019
…atticgh-280 # Conflicts: # src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParser.java # src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java # src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java # src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd # src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java # src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java
Walliee
added a commit
to Walliee/spring-integration-kafka
that referenced
this issue
Aug 25, 2019
* Refactored to topics/topicPattern to be a property to prevent constructor telescoping resolves spring-attic#280
Walliee
added a commit
to Walliee/spring-integration-kafka
that referenced
this issue
Aug 25, 2019
* Refactored to topics/topicPattern to be a property to prevent constructor telescoping resolves spring-attic#280
Walliee
added a commit
to Walliee/spring-integration-kafka
that referenced
this issue
Aug 25, 2019
…atticgh-280 # Conflicts: # src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java
artembilan
pushed a commit
that referenced
this issue
Aug 28, 2019
Fixes #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
garyrussell
pushed a commit
to garyrussell/spring-integration
that referenced
this issue
Jun 24, 2020
Fixes spring-attic/spring-integration-kafka#280 * Refactored to topics/topicPattern to be a property to prevent constructor telescoping * Add support for manual partition assignment - Cleanup after rebasing from spring-projects#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
artembilan
pushed a commit
to spring-projects/spring-integration
that referenced
this issue
Jun 25, 2020
Fixes spring-attic/spring-integration-kafka#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
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
It'd be good to support pattern-based subscriptions in
KafkaMessageSourcejust likeKafkaMessageListenerContainerThe text was updated successfully, but these errors were encountered: