spring - Spring Boot Kafka 启动错误“无法建立与节点 -1 的连接。代理可能不可用。”
问题描述
我正在尝试使用 Java 12 在本地主机上使用 Spring Boot 2.1.7.RELEASE 启动 Spring-Kafka。
出现错误:“org.apache.kafka.clients.NetworkClient:[Consumer clientId=consumer-1, groupId=inter] 无法建立到节点 -1 的连接。代理可能不可用。”
我尝试将 Java 版本切换到 11 和 8 以及各种属性
spring:
kafka:
consumer:
#bootstrap-servers: localhost:9092
group-id: inter
auto-offset-reset: earliest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
producer:
bootstrap-servers: localhost:9092
@Service
public class KafkaHalloWorldMessagingService {
private KafkaTemplate<String, String> kafkaTemplate;
@Autowired
public KafkaHalloWorldMessagingService(KafkaTemplate<String, String> kafkaTemplate) {
this.kafkaTemplate = kafkaTemplate;
}
public void sendHalloToTheSystem(String messageToSend) {
kafkaTemplate.send("interlinked.hallo.topic", messageToSend);
}
}
@Component
public class KafkaHalloWorldListener {
@KafkaListener(topics = "interlinked.hallo.topics", groupId = "inter")
public void handle(String messageToListenTo) {
System.out.println(messageToListenTo.toUpperCase());
}
}
2019-08-22 16:25:20.580 WARN 5865 --- [restartedMain] org.apache.kafka.clients.NetworkClient:[Consumer clientId=consumer-1, groupId=inter] 无法建立到节点 -1 的连接。经纪人可能不可用。
解决方案
确保 yml 文件中的引导服务器值和 Kafka server.properties 文件中的侦听器值相同。
更新 server.properties 文件中的这两个值。可以在Kafka下载目录的config文件夹中看到。
zookeeper.connect=您的 IpV4 地址:2181
listeners=PLAINTEXT://您的 IpV4 地址:9092
例如:zookeeper.connect=10.147.2.161:2181
为什么消费者的引导服务器属性被注释掉了?
请也将生产者的引导服务器值用于消费者。
spring.kafka.bootstrap-servers = Your IpV4 addrees:9092
或拆分
producer:
bootstrap-servers: =Your IpV4 addrees:9092
consumer:
bootstrap-servers: =Your IpV4 addrees:9092:
希望你的动物园管理员和卡夫卡起来了。
推荐阅读
- java - 我应该如何在现有父级的基于一对多注释的映射中执行更新操作?
- javascript - 避免使用带有 React+Redux 的 array.map 重新渲染组件
- javascript - Rails Uncaught TypeError: $(...).owlCarousel 不是函数
- javascript - Typescript:让模块解析(路径/基础)、动态导入和 resolveJsonModule 协同工作
- exception - Couchbase Spring 应用程序中的视图不存在异常。视图不存在
- angular - 如何根据绝对或相对 url 将 url 分配给锚标记,href 总是使用 routerLink 更新,这是默认情况下发生的吗?
- python - ValueError:图像不是数字,而是 ndarray
- python - Pip 不安装 setup.py 中声明的依赖项 install_requires
- javascript - 来自“throw”语句的意外“未定义”输出
- c# - 调整对象上指定类型的所有属性