admin管理员组

文章数量:1294642

首先引入jar包：

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

然后配置链接信息：

data:
  kafka:
    groupId: xxxxx
    bootstrapServers:  127.0.0.1:8080
    userName: kafka
    password: kafka
    topic: xxxxxxx

再编写配置类等。

启动后报错：

Description:

Parameter 0 of method loadBalancedRetryFactory in org.springframework.cloud.loadbalancer.config.BlockingLoadBalancerClientAutoConfiguration$BlockingLoadBalancerRetryConfig required a bean of type 'org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer$Factory' that could not be found.


Action:

Consider defining a bean of type 'org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer$Factory' in your configuration.

解决办法：

spring:
  cloud:
    loadbalancer:
      enabled: true

在配置文件中加入loadbalancer为true 即可解决。

本文标签： 报错definingBeanKafkaSpringBoot

版权声明：本文标题：springboot集成kafka报错解决：Consider defining a bean of type org.springframework.cloud.client.loadbalancer 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.betaflare.com/biancheng/1738334278a2076621.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。