如何删除此有关conluent.monitoring.interceptor的警告？

Question

我在使用Spring-Kafka的Spring Boot2.2.2服务中使用KafkaTemplate向Kafka发布消息。消息正在成功发布，但是，一旦我发布第一条消息，我的日志就会被以下警告淹没：

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

我想我要么拼错了一个属性，要么把它放错了地方，但我不知道是什么。这是我的yaml的样子：

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内容需要放在属性部分下