kafka 高级消费者的注解配置

Question

我想知道是否有一种方法可以配置 kafka-integration 入站通道适配器，如https://github.com/spring-projects/spring-integration-kafka 中所述，使用 Java 注释而不是 xml。我不太明白它的线索。我能够配置消息驱动通道适配器，但现在我需要一个在重新启动服务器时不会重新读取已使用消息的适配器

Answer 1

注解配置见main Spring Integration Documentation；另见Java DSL。

我们正在添加越来越多的 java 配置示例；例如，请参阅here。

kafka 高级消息源将配置为@InboundChannelAdapter @Bean。