为什么德贝兹连接器无法连接到 SASL 激活的代理？

Question

我正在尝试为我的Kafka系统启用 SASL/普通。它实际上可以工作，我已经针对模式注册表和Java生产者对其进行了测试。问题是 Kafka Connect 在启用 SASL 时无法建立连接（至少这是我首先想到的）。我给出了必要的配置，但看起来它根本没有影响。我已经编辑了我的连接 - avro-分布式.properties文件为：

sasl.mechanism=PLAIN
security.protocol=SASL_PLAINTEXT
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="admin" \
  password="secret";

producer.sasl.mechanism=PLAIN
producer.security.protocol=SASL_PLAINTEXT
producer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="admin" \
  password="secret";

consumer.sasl.mechanism=PLAIN
consumer.security.protocol=SASL_PLAINTEXT
consumer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
  username="admin" \
  password="secret";

但在日志中它说：

[2022-01-07 12:21:28,645] INFO ProducerConfig values:
        sasl.mechanism = GSSAPI
        security.protocol = PLAINTEXT

这应该像：

[2022-01-07 12:21:28,645] INFO ProducerConfig values:
        sasl.mechanism = PLAIN
        security.protocol = SASL_PLAINTEXT

消费者配置也是如此。我需要做什么？为什么它带有默认值？我已经重启服务很多次了。提前感谢。

编辑：还有另一个连接器可以毫无问题地运行，并且它具有SASL的正确配置。

Edit2:看起来Debezium连接器在连接器方面需要更多的配置。

Answer 1

使用不同的连接器进行尝试可以清楚地看出存在Debezium特定的问题。由于Debezium使用历史主题，因此在启用安全性时需要一些额外的配置。

"database.history.consumer.security.protocol": "SASL_PLAINTEXT",
"database.history.consumer.sasl.mechanism": "PLAIN",
"database.history.consumer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"admin\" password=\"secret\";",
"database.history.producer.security.protocol": "SASL_PLAINTEXT",
"database.history.producer.sasl.mechanism": "PLAIN",
"database.history.producer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"admin\" password=\"secret\";"

您需要覆盖Debezium连接器的生产者和消费者配置的默认值。如果使用SSL，您需要添加几行代码。有关详细信息，请访问:https://docs . confluent . io/debezium-connect-SQL server-source/current/SQL server _ source _ connector _ config . html