Spring Boot 微服务作为 Kafka 消费者异常

Question

我正在尝试将 kafka 集成到我的 Spring Boot 项目中，但我遇到了一个异常。

2021-07-13T13:22:13.12+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.129+08:00","@version":"1","message":"Located property sour
igService', propertySources=[MapPropertySource {name='configClient'}, MapPropertySource ]}","logger_name":"org.springframework.cloud.bootstrap.config.PropertySourceBootstrapConfiguration","thread_name":"main","level":"INFO"
   2021-07-13T13:22:13.14+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.148+08:00","@version":"1","message":"'cloud' property sour
ry.reconfiguration.CloudPropertySourceApplicationContextInitializer","thread_name":"main","level":"INFO","level_value":20000}
   2021-07-13T13:22:13.14+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.149+08:00","@version":"1","message":"Reconfiguration enabl
onfiguration.CloudServiceReconfigurationApplicationContextInitializer","thread_name":"main","level":"INFO","level_value":20000}
   2021-07-13T13:22:13.15+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.156+08:00","@version":"1","message":"Refreshing org.spring
ConfigApplicationContext@57e03347: startup date [Tue Jul 13 13:22:13 SGT 2021]; parent: org.springframework.boot.web.servlet.context.AnnotationCo
290dbf45","logger_name":"org.springframework.context.annotation.AnnotationConfigApplicationContext","thread_name":"main","level":"INFO","level_va
   2021-07-13T13:22:13.19+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.193+08:00","@version":"1","message":"Skipping reconfigurat
igured","logger_name":"org.cloudfoundry.reconfiguration.CloudServiceReconfigurationBeanFactoryPostProcessor","thread_name":"main","level":"INFO",
   2021-07-13T13:22:13.21+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.215+08:00","@version":"1","message":"JSR-330 'javax.inject
 for autowiring","logger_name":"org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor","thread_name":"main","level":"
   2021-07-13T13:22:13.41+0800 [APP/PROC/WEB/0] OUT {"@timestamp":"2021-07-13T13:22:13.410+08:00","@version":"1","message":"Exception encountered
ling refresh attempt: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'binderHealthIndicator' def
m.binder.rabbit.config.RabbitServiceAutoConfiguration$RabbitHealthIndicatorConfiguration: Unsatisfied dependency expressed through method 'binder
ception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'rabbitTemplate' defined in org.spring
nfig.RabbitServiceAutoConfiguration$CloudProfile$CloudConnectors$UseCloudConnectors: Unsatisfied dependency expressed through method 'rabbitTempl
rg.springframework.beans.factory.BeanCreationException: Error creating bean with name 'rabbitConnectionFactory' defined in org.springframework.cl
erviceAutoConfiguration$CloudProfile$CloudConnectors$UseCloudConnectors: Bean instantiation via factory method failed; nested exception is org.sp
ception: Failed to instantiate [org.springframework.amqp.rabbit.connection.ConnectionFactory]: Factory method 'rabbitConnectionFactory' threw exc
ramework.cloud.CloudException: No unique service matching interface org.springframework.amqp.rabbit.connection.ConnectionFactory found. Expected
amework.context.annotation.AnnotationConfigApplicationContext","thread_name":"main","level":"WARN","level_value":30000}

pom.xml

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-kafka-streams</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-kafka</artifactId>
        </dependency>
        <dependency>
           <groupId>io.pivotal.spring.cloud</groupId>
           <artifactId>spring-cloud-services-starter-service-registry</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-spring-service-connector</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-cloudfoundry-connector</artifactId>
        </dependency>

知道我错过了什么吗？

这是我的参考教程 https://www.youtube.com/watch?v=xyaFygU9C2Q

谢谢！

Answer 1

添加 rabbitTemplate 相关依赖并在您的配置类中创建 rabbitTemplate bean 然后执行 Autowireing。

如果不使用从你的代码中删除 rabbitTemplate 相关的配置。