Spring Boot 和 Kafka：Broker 断开连接

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

适用于仅适用于消费者的属性（同样适用于生产者和管理员）。