1

我有一个在 Azure k8s 中运行的服务，并尝试使用来自 Confluent Cloud（Kafka SaaS 解决方案）的消息。

获取以下错误跟踪：

[main] INFO org.apache.kafka.common.security.authenticator.AbstractLogin - 

Successfully logged in.
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.7.0
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 448719dc99a19793
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1630412312849
[main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-test-1, groupId=test] Subscribed to topic(s): pricing.cdc.selling-prices.segment
[main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-test-1, groupId=test] Connection to node -1 (52.151.125.243/52.151.125.243:9092) terminated during authentication.

相同的配置适用于本地 k8s 集群和配置的 Apache Kafka 防火墙规则。关于可能原因的任何想法？

4

1 回答 1

3

  1. 尝试新环境后立即检查密钥和密码是否正确。

  2. 检查是否启用了 SSL 协议。为此，请放置额外的财产

    props.put("ssl.enabled.protocols", "TLSv1.2")

    到您的代码或配置文件。

  3. 模式注册表呢？与模式注册表的连接是否有效？

于 2021-09-09T10:32:34.930 回答