Spring Boot Kafka启动错误“无法建立到节点-1的连接。代理可能不可用。”

Question

我试图用Spring Boot 2.1.7启动Spring-Kafka。用Java12在localhost上发布。

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());
    }
}

Answer 1

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

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

zookeeper.connect=您的IpV4地址：2181

spring.kafka.bootstrap-servers = Your IpV4 addrees:9092

或分裂

producer:
     bootstrap-servers: =Your IpV4 addrees:9092
consumer:
     bootstrap-servers: =Your IpV4 addrees:9092:

希望你的动物园管理员和Kafka都起来了。