Issue Guidelines

I use MqttSourceConnector and would like to replicate shared MQTT subscription to all workers.
connect.mqtt.clean=true
connector.class=com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
tasks.max=4
connect.mqtt.kcql=INSERT INTO SESSION_CHAT_DATA_TOPIC SELECT * FROM $share/g/chat
connect.mqtt.password=***********
connect.mqtt.share.replicate=true

As a result only 1 worker is created. To fix this issue I need update kcql string to the following:
connect.mqtt.kcql=INSERT INTO SESSION_CHAT_DATA_TOPIC SELECT * FROM $share/g/chat;INSERT INTO SESSION_CHAT_DATA_TOPIC SELECT * FROM $share/g/chat

Just duplicate kcql string with ';' separator that is not good and proper way

Please review these questions before submitting any issue?

What version of the Stream Reactor are you reporting this issue for?

3.0.1

Have you read the docs?

yes

What is the expected behaviour?

I think if connect.mqtt.share.replicate=true the kcql query should be one like INSERT INTO SESSION_CHAT_DATA_TOPIC SELECT * FROM $share/g/chat and replicated to all workers