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

My rabbitmq connector works fine when I run it in a server with no SASL. Actually it was working in a SASL activated server too but after restarting the Kafka Connect service now it won't start working. The error is:

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.

Is it a licensing issue? I don't think we purchased any license for it and it says there is a 30 days free trial. But also, I think we were using it for more than 30 days.

Edit: Found this in connect.log file:

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

Edit2: It has something to do with SASL. After enabling SASL for my broker, rabbitmq connector started giving this error.



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source