Приложение весенней загрузки конвейера kafka с ошибкой «Не удалось установить соединение с узлом -1. Брокер может быть недоступен».

Question

2020-02-26 18:08:54.925  WARN 4472 --- [| adminclient-1] org.apache.kafka.clients.NetworkClient   : [AdminClient clientId=adminclient-1] Connection to node -1 could not be established. Broker may not be available.

Ниже приведен файл `` application.yaml``

spring:
  cloud:
    stream:
      default:
        producer:
          useNativeEncoding: true
        consumer:
          useNativeEncoding: true
      bindings:
        input:
          destination: employee-details
          content-type: application/*+avro
          group: group-1
          concurrency: 3
        output:
          destination: employee-details
          content-type: application/*+avro
      kafka:
        binder:
          producer-properties:
            key.serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
            value.serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
            schema.registry.url: http://localhost:8081
          consumer-properties:
            key.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
            value.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
            schema.registry.url: http://localhost:8081
            specific.avro.reader: true

Я попытался запустить curl -X POST https://localhost:9092/employees/1001/Harry/Potter на cmd, но выдал ошибку curl: (7) Не удалось подключиться к локальному порту 9092: соединение отказано

Answer 1

У вас, кажется, есть фундаментальное недоразумение. connect to localhost port 9092: Connection refused Порт 9092 обычно является портом Kafka, а не портом HTTP; учитывая, что вы получаете Broker may not be available. и Connection Refused, когда пытаетесь соединиться с curl, это означает, что у вас не работает Kafka на localhost, и вы, конечно, не можете подключиться к нему по HTTP, даже если он там работал.