How to set up MQTT Connector in an MSK environment

Apache Kafka Connectors
1

Hello.

When setting up the MQTT connector in my MSK environment, for some reason my setup is consistently failing to deploy.
I must be missing something, but I don’t know what it is.

I need the ability to:

  1. configure a Lenses mqtt connector to MSK
  2. monitor via the Lenses UI installed on ECS or EC2.

I am currently having trouble progressing on #1.
Below is the setup I have configured, and it hasn’t deployed for 30 minutes now without any errors.

{
  "connector.class": "io.lenses.streamreactor.connect.mqtt.source.MqttSourceConnector",
  "connect.mqtt.username": "tester",
  "tasks.max": "1",
  "name": "mqtt-source",
  "connect.mqtt.kcql": "INSERT INTO mqtt SELECT * FROM /mjson WITHCONVERTER=`io.lenses.streamreactor.connect.converters.source.JsonSimpleConverter`",
  "connect.mqtt.password": "my_password",
  "connect.mqtt.service.quality": "1",
  "connect.mqtt.client.id": "msk_source_id",
  "connect.mqtt.hosts": "tcp://my_external_test_host:1883"
}

For the MQTT server, deployment and access were verified as normal on the local and development servers.