springboot集成kafka报错解决：Consider defining a bean of type org.springframework.cloud.client.loadbalancer

springboot集成kafka报错解决：Consider defining a bean of type org.springframework.cloud.client.loadbalancer

首先引入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 即可解决。