RabbitMQ 连接器给出 "TimeoutException: License topic could not be created"

Question

当我运行在没有 SASL 的服务器上时，我的 rabbitmq 连接器工作正常。实际上它也在 SASL 激活的服务器上工作，但在重新启动 Kafka Connect 服务后它现在不会开始工作。错误是：

org.apache.kafka.common.errors.TimeoutException: License topic could not be created
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

这是许可问题吗？我不认为我们为它购买了任何许可证，它说有 30 天的免费试用期。而且，我想我们已经用了 30 多天了。

编辑：在 connect.log 文件中找到：

INFO [AdminClient clientId=RabbitMQSinkConnector2-license-manager] Metadata update failed

Edit2：与SASL有关。为我的代理启用 SASL 后，rabbitmq 连接器开始出现此错误。

Answer 1

通过为启用 sasl 的代理添加一些额外的配置来解决它，就像我为 debezium 连接器所做的那样。您需要将这些行添加到您的连接器配置中：

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

如果您不想公开您的 sasl 凭据，您可以将其保存在一个文件中，然后像这样更改最后一个：

"confluent.topic.sasl.jaas.config": "${file:/kafka/vty/pass.properties:sasl}"

当然你需要先启用从文件读取。

RabbitMQ 连接器给出 "TimeoutException: License topic could not be created"

RabbitMQ Connector gives "TimeoutException: License topic could not be created"

apache-kafka

rabbitmq

apache-kafka-connect