1

我正在尝试连接到 IBM 的托管 Apache Kafka 解决方案。这就是 IBM 在其文档中声明的连接 bootstrap.servers=broker-2-****.kafka.svc03.us-***.cloud.ibm.com:9093, sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="token" password="<api_key>";, sasl.mechanism=PLAIN, security.protocol=SASL_SSL,ssl.protocol=TLSv1.2

这就是我在代码中配置的方式

var config = new ProducerConfig
       {
           BootstrapServers = "broker-****.kafka.svc03.us-south.eventstreams.cloud.ibm.*,****.kafka.****.eventstreams.cloud.ibm.***",
           SaslMechanism = SaslMechanism.Plain,
           Debug = "broker,security,protocol",
           EnableSslCertificateVerification = false,
           SocketTimeoutMs = 5000,
           SaslUsername = "token",
           SaslPassword = "******",
           SecurityProtocol = SecurityProtocol.SaslSsl
       };

但是我无法在 c# 代码中设置 ssl.protocol=TLSv1.2。不确定这是否是问题的原因。无论如何，这是我得到的错误。错误日志链接

我试图了解日志，但我怀疑版本控制有问题，无法找出确切的问题。

我正在运行：

  1. 点网核心 3.1
  2. Confluent.Kafka(1.4.0)。如果您需要更多详细信息，请告诉我
4

0 回答 0