MQTT Source Connect - WARN Property 'topics' cannot be found

Apache Kafka Connectors
1

Hi
I’m trying to setup a mqtt source connector but i keep getting status error 400. The logs are displaying this as an issue.

WARN - io.lenses.config.kafka.connect.SimpleTopicsExtractor Property 'topics' can not be found in the properties

Could you help in what is missing please

My config so far

name=mqtt-source
connector.class=io.lenses.streamreactor.connect.mqtt.source.MqttSourceConnector
tasks.max=1
connect.mqtt.kcql=INSERT INTO mqtt SELECT * FROM mjson WITHCONVERTER=`io.lenses.streamreactor.connect.converters.source.JsonSimpleConverter`
connect.mqtt.client.id=clientid1
connect.mqtt.hosts=tcp://ipaddress:1883 
connect.mqtt.service.quality=1
connect.mqtt.username=username1
connect.mqtt.password=password1
2

Hello KayG,

The connectors have minimum settings to work, and it varies from connector to connector. In your case, you need to add the key “topics” and the name of a topic in your configuration, such as “topics=my_topic” for example.

Best,
Victor

3

Thanks for the reply.

Correct me if i am wrong, the ‘topics’ property seems to be required for a Sink Connector and not for a Source Connector according to the documentation.

Could this be an issue with lenses?

Kind regards
Kershan

4

This will be fixed in the Lenses 5.4.4 which should be available on the 23rd of February.

Stefan

1 Like