spring-integration-kafka注解支持&示例

spring-integration-kafka annotation support & example

虽然是 spring 的新手,但我通常仅使用注释就能很好地开始 spring 项目。官方示例使用 xml 没有提及它们将放置在何处等

是否有任何关于从 kafka 主题阅读的示例项目?最好使用注释来设置 zk 和 kafka 配置属性。

请查看 Spring Integration Java DSL project and here is a KafkaTests 以演示如何适合您的情况。

另外还有 Josh Long 的文章:https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring