spring-boot - Spring Boot 和 Kafka : Broker disconnected

Question

我已经设置了一个 Spring Boot 应用程序来接收来自现有和工作的 Kafka 生产者的 Kafka 消息。设置是标准的，并基于以下内容:https://www.codenotfound.com/spring-kafka-consumer-producer-example.html

收不到消息，控制台不断显示:

WARN org.apache.clients.NetworkClient :Bootstrap broker <hostname>:9092 disconnected 

此外，还会记录以下调试消息:

org.apache.common.errors.Timeout: Failed to update metadata after 60000 ms.

控制台消息在以下链接中讨论: https://community.hortonworks.com/content/supportkb/150148/errorwarn-bootstrap-broker-6668-disconnected-orgap.html

记录的消息在这里讨论: https://community.cloudera.com/t5/Data-Ingestion-Integration/Error-when-sending-message-to-topic-in-Kafka/td-p/41440

第一个问题解决后，很有可能不会超时。

给出的控制台消息的解决方案是将 --security-protocol SSL 作为参数显式传递给生产者或消费者命令。

鉴于我正在监听现有的 Kafka 代理和主题，因此无法更改那里的任何设置。任何更改都必须在 Spring Boot 端。

是否可以配置 application.yml 以便将 --security-protocol SSL 作为参数传递给消费者？另外，有没有人以前遇到过这种情况，还有其他方法可以使用 Spring Boot 和 Spring Kafka 中可用的配置选项来解决这个问题吗？

谢谢

Answer 1

参见 the documentation .

向下滚动到 Kafka。可以使用

设置任意 Kafka 属性

spring:
  kafka:
    properties:
      security.protocol: SSL

适用于消费者和生产者(以及 2.0 中的管理员)。

在即将发布的2.0版本中(目前是RC1)，还有

spring:
  kafka:
    properties:
      consumer:
        some.property: foo

仅适用于消费者的属性(生产者和管理员也同样如此)。