spring-cloud - Spring Cloud Stream无法检测消息路由器

Question

我正在尝试设置一个简单的云流接收器，但不断遇到以下错误。

我尝试了几种 Binder ，但它们都一直给出相同的错误。

 "SEVERE","logNameSource":"org.springframework.boot.diagnostics.LoggingFailureAnalysisReporter","message":"
***************************
APPLICATION FAILED TO START
***************************
Description:
Parameter 0 of method binderAwareRouterBeanPostProcessor in org.springframework.cloud.stream.config.BindingServiceConfiguration required a bean of type '[ Lorg.springframework.integration.router.AbstractMappingMessageRouter;' that could not be found.
Action:
Consider defining a bean of type '[ Lorg.springframework.integration.router.AbstractMappingMessageRouter;' in your configuration.  

我正在尝试使用一个简单的接收器来记录来自 kafka 主题的传入消息

@EnableBinding(Sink.class)
public class ReadEMPMesage {
    private static Logger logger = 
    LoggerFactory.getLogger(ReadEMPMesage.class);

    public ReadEMPMesage() {
        System.out.println("In constructor");
    }


    @StreamListener(Sink.INPUT)
    public void loggerSink(String ccpEvent) {
        logger.info("Received" + ccpEvent);
    }

}    

我的配置如下

# Test consumer properties
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.group-id=testEmbeddedKafkaApplication
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer

# Binding properties
spring.cloud.stream.bindings.output.destination=testEmbeddedOut
spring.cloud.stream.bindings.input.destination=testEmbeddedIn
spring.cloud.stream.bindings.output.producer.headerMode=raw
spring.cloud.stream.bindings.input.consumer.headerMode=raw
spring.cloud.stream.bindings.input.group=embeddedKafkaApplication

还有我的 pom

    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-stream-kafka</artifactId>
    </dependency>



   <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream</artifactId>
    </dependency>

Answer 1

TL;DR - 检查您的 Spring Boot 版本并尝试将其升级一些小版本。

从 Spring Cloud DALSTON.RELEASE 升级到 Spring Cloud Edgware.SR4 后，我在一个项目上遇到了这个问题——这很奇怪，因为其他项目工作正常，但是有一个没有。

经过进一步调查，我意识到麻烦制造者项目正在使用 Spring Boot 1.5.3.RELEASE，而其他项目正在使用 1.5.9.RELEASE

将 Spring Boot 升级到 1.5.9.RELEASE 后，一切似乎开始工作