Kafka Streams function detection improvements

spring-cloud / spring-cloud-stream-binder-kafka

Spring Cloud Stream binders for Apache Kafka and Kafka Streams

Apache License 2.0

331 stars 301 forks source link

Kafka Streams function detection improvements #1033

Closed sobychacko closed 3 years ago

sobychacko commented 3 years ago

Allow Kafka Streams functions defined as Component beans to be candidates for establishing bindings. Currently, Kafka Streams functions need to be written as functional beans using @Bean. Adding this improvement so that if applications prefer to write the business logic using @Component, then it is possible to do so.

Adding test cases to verify the behavior.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1030

sobychacko commented 3 years ago

Thank you @olegz. I am making the changes from your review.