MQTT Source Connector error

Kafka Connect Self-Managed Connectors
1

I try to set up an MQTT Source Connector with Kafka Connect running in Docker. I set the simple example used in the official Confluent page https://docs.confluent.io/kafka-connectors/mqtt/current/mqtt-source-connector/overview.html#install-the-mqtt-connector-plugin
without a license and i get this error in my docker logs
ERROR WorkerConnector{id=MqttSourceConnector} Error while starting connector (org.apache.kafka.connect.runtime.WorkerConnector)
java.lang.NoSuchMethodError: ‘org.apache.kafka.connect.util.TopicAdmin$NewTopicBuilder org.apache.kafka.connect.util.TopicAdmin$NewTopicBuilder.minInSyncReplicas(short)’
at io.confluent.license.LicenseStore.setupAndCreateKafkaBasedLog(LicenseStore.java:185)

2

This is a known issue that we are working to address. Specifically, it is a regression against Apache Kafka 3.8 (apache/kafka or apache/kafka-native) and Confluent Community 7.8 (confluentinc/cp-kafka). It would not crop up against Confluent Enterprise 7.8 (confluentinc/cp-server). For Apache Kafka or Confluent Community, I’d recommend downgrading to 3.7 or 7.7, respectively, to test this connector.

1 Like