Ошибка при создании bean-компонента с именем CompositMessageChannelConfigurer, определенного в org.springframework.cloud.stream.config.BinderFactoryAutoConfiguration - PullRequest
0 голосов
/ 25 марта 2020

введите описание изображения здесь

Микросервис 1:

идентификатор артефакта - microservice1 Defined KafkaStreams. java интерфейс, в котором определен свойства связывателя, как показано ниже.

public interface KafkaStreams {

    String OUTPUT = "kafka-output";

    String INPUT = "kafka-input";

    @Input(INPUT)
    SubscribableChannel getInputChannel();

    @Output(OUTPUT)
    MessageChannel getOutboundMessageChannel();
}

Микросервис 2: id артефакта - microservice2

В микросервисе 2 добавлен микросервис зависимостей1 и предоставлены облачные свойства брокеру conf и topi c имен.

spring:
  application:
    name: business-service
  cloud:
    stream:
      default-binder: kafka1
      function:
        definition: 
      kafka:
        binder:
          brokers:
            - localhost:9092
          configuration:
            default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
            default.value.serde: org.apache.kafka.common.serialization.Serdes$BytesSerde
            commit.interval.ms: 1000
            security.protocol: SASL_PLAINTEXT      
      bindings:
        kafka-input:
          destination: topic1
          contentType: text/plain
          binder: kafka1
        kafka-output:
          destination: topic2
          contentType: text/plain
          binder: kafka1      
      binders:
        kafka1:
         type: kafka
         environment:
           spring:
             cloud:
               stream:
                kafka:
                  binder:
                    brokers: localhost:9092

Трассировка стека:

2020-03-25T15:21:09.748+08:00 [APP/PROC/WEB/0] [OUT] Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'compositeMessageChannelConfigurer' defined in org.springframework.cloud.stream.config.BinderFactoryAutoConfiguration: Unsatisfied dependency expressed through method 'compositeMessageChannelConfigurer' parameter 0; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'org.springframework.cloud.stream.binding.MessageConverterConfigurer' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {}
2020-03-25T15:21:09.748+08:00 [APP/PROC/WEB/0] [OUT] at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:798) ~[spring-beans-5.2.3.RELEASE.jar:5.2.3.RELEASE]
2020-03-25T15:21:09.748+08:00 [APP/PROC/WEB/0] [OUT] at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:539) ~[spring-beans-5.2.3.RELEASE.jar:5.2.3.RELEASE]
2020-03-25T15:21:09.748+08:00 [APP/PROC/WEB/0] [OUT] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1338) ~[spring-beans-5.2.3.RELEASE.jar:5.2.3.RELEASE]
2020-03-25T15:21:09.748+08:00 [APP/PROC/WEB/0] [OUT] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1177) ~[spring-beans-5.2.3.RELEASE.jar:5.2.3.RELEASE]

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...