当前位置: 首页 > 知识库问答 >
问题:

Spring Boot Kafka Startup error“无法建立到节点-1的连接。代理可能不可用。“

尉迟宣
2023-03-14

获取错误:“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警告5865---[restartedMain]org.apache.kafka.clients.NetworkClient:[Consumer ClientID=Consumer-1,GroupID=Inter]无法建立到节点-1连接。代理可能不可用。

共有1个答案

高嘉熙
2023-03-14

确保yml文件中的引导服务器值和Kafka server.properties文件中的侦听器相同。

更新server.properties文件中的这两个值。可以在Kafka下载目录的config文件夹中看到。

zookeeper.connect=您的IpV4 Addrees:2181

为什么使用者的引导带服务器属性会被注释掉呢?

请也为消费者使用生产者的引导带服务器值。生产者:bootstrap-servers:=您的IpV4 Addrees:9092消费者:bootstrap-servers:=您的IpV4 Addrees:9092:

希望你的饲养员和Kafaka起来了。

 类似资料:
  • 我试图用Spring Boot 2.1.7启动Spring-Kafka。用Java12在localhost上发布。

  • 我在Zookeeper和Kafka(各1个实例)中运行我的locahost。 我成功地从Kafka创建了一个主题: Kafka日志显示: 但Zookeeper的日志显示: 如果我尝试生成消息: server.properties(在Kafka中)是: 看来动物园管理员没有注册任何经纪人。 有什么建议吗?

  • 我正试图在我的本地(windows 7虚拟桌面)中使用来自Kafka的消息 Zookeeper和kafka在同一台本地计算机上运行 创建主题 produce message kafka-console-producer--broker-list 127.0.0.1:9092--topic first_topic没有错误,我只是做Ctrl+C do end producing 使用邮件

  • 问题内容: 我只是不明白发生了什么。我的go应用程序无法连接到elasticsearch。该节点可用,已启动并正在运行。我在这里做错了什么? 这里有什么不对的地方?错误说 这是我在浏览器中命中GET请求时从elasticsearch返回的数据 } 问题答案: 当您继续在客户端中进行嗅探但群集没有可用节点时,通常会发生错误。您可以通过点击来检查集群的状态。 如果您不禁用嗅探功能,则Golang客户端

  • 问题内容: 我只是不明白发生了什么。我的go应用程序无法连接到弹性搜索。该节点可用,已启动并正在运行。我在这里做错了什么? 这里有什么不对的地方?错误说 这是我在浏览器中命中GET请求时从弹性搜索返回的数据 } 问题答案: 当您继续在客户端中进行嗅探但群集没有可用节点时,通常会发生错误。您可以通过点击来检查集群的状态。 如果您不禁用嗅探功能,则Golang客户端将在后台运行进程,该进程每15分钟轮

  • 下面是Qpid客户端的配置,使用Camel上下文连接Artemis Broker。 上下文文件正像预期的那样开始,但是在本例中,qpid客户机无法连接到Apache Artemis 2.14.0代理。 我所看到的只是消费者端的一些线程块。 common-context.xml 注意:在使用CAMEL2.20.0版本时,即使在所有上下文都得到的情况下,这个单个xml文件中也有两个camel上下文