Я пытаюсь подключиться к управляемому решению 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
};
Однако я не смог установить ssl.protocol = TLSv1.2 в c# коде. Не уверен, что это является причиной проблемы. В любом случае, вот ошибка, которую я получаю. Ссылка на журналы ошибок
Я попытался разобраться в журналах, и я подозреваю, что что-то с управлением версиями, не могу выяснить точную проблему.
Я работаю на:
- Do tnet core 3.1
- Confluent.Kafka (1.4.0). Дайте мне знать, если вам нужно больше деталей