kcat 连接到 Kafka 集群设置，无需身份验证

Question

我正在尝试列出未进行身份验证设置的 Kafka 集群上的主题。我正在使用命令行，其中 b1 和 b2 是经纪人名称。

kcat -b b1:9094,b2:9094 -F kc.properties -L

我的kc.properties如下图：

bootstrap.servers="b1:9094,b2:9094"
security.protocol=PLAINTEXT

我也尝试过不添加“security.protocol”行。

但是，我收到以下错误消息：

Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 38ms in state APIVERSION_QUERY

经纪商使用 AWS MSK 版本 2.2.1

Answer 1

我能够通过将 security.protocol 设置为 SSL 进行连接，如下所示：

bootstrap.servers="b1:9094,b2:9094"
security.protocol=SSL