Как убрать это предупреждение о conluent.monitoring.interceptor?

Question

Я публикую сообщение для Kafka, используя KafkaTemplate в сервисе Spring Boot 2.2.2, используя Spring-Kafka. Сообщения успешно публикуются, однако мои журналы заполнены следующим предупреждением, как только я публикую sh первое сообщение:

[Producer clientId=confluent.monitoring.interceptor.fagfgfsgas-1] Bootstrap broker confluent-kafka.eabcd.com:1234 (id: -1 rack: null) disconnected

Я думаю, что я либо неправильно написал одно из свойств, либо потерял его, но я не могу понять, что. Вот как выглядит моя ямля:

spring:
  kafka:
    producer:
      client-id: "abcd"
      acks: 1
      bootstrap-servers: confluent-kafka.eabcd.com:1234
      key-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
      value-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
      confluent.monitoring.interceptor.sasl.mechanism: PLAIN
      confluent.monitoring.interceptor.security.protocol: SASL_PLAINTEXT
      confluent.monitoring.interceptor.sasl.jaas.config: 'org.apache.kafka.common.security.plain.PlainLoginModule required username="username" password="password";'
      properties:
        request.timeout.ms: 10000
        retry.backoff.ms: 500
        schema.registry.url: https://confluent-schemaregistry.abcdef.com
        ssl.endpoint.identification.algorithm: http
        sasl.jaas.config: 'org.apache.kafka.common.security.plain.PlainLoginModule required username="username" password="password";'
        security.protocol: SASL_PLAINTEXT
        sasl.mechanism: PLAIN
        interceptor.classes: io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor

Answer 1

Это говорит о том, что ваше соединение с bootstrap-servers не может быть установлено

Я предлагаю вам отладить код без interceptor.classes

и confluent.monitoring.interceptor вещей нужно go в разделе свойств