A connector plugin to use with Kafka's Connect API. It can be configured to map any topic from an mqtt broker to any topic on the Kafka broker. The connector can be configured to use SSL in communication with the mqtt broker.
This code seems to depend on a very specific message format and cant seem to find documentation on it.
ERROR MqttSourceConnectorTask ERROR: Not able to create source record from mqtt message '{
"msg": "test event 6"
}' arrived on topic 'dev-events' for client 'kafka_source_connector'.
ERROR MqttSourceConnectorTask java.lang.ArrayIndexOutOfBoundsException: Index 21 out of bounds for length 1
java.lang.ArrayIndexOutOfBoundsException: Index 21 out of bounds for length 1
at java.base/java.util.Arrays$ArrayList.get(Arrays.java:4351)
at com.sintef.asam.MqttSourceConnectorTask.makeDBDoc(MqttSourceConnectorTask.java:160)
at com.sintef.asam.MqttSourceConnectorTask.messageArrived(MqttSourceConnectorTask.java:126)
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:513)
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:416)
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:213)
at java.base/java.lang.Thread.run(Thread.java:829)
This code seems to depend on a very specific message format and cant seem to find documentation on it.
ERROR MqttSourceConnectorTask ERROR: Not able to create source record from mqtt message '{ "msg": "test event 6" }' arrived on topic 'dev-events' for client 'kafka_source_connector'. ERROR MqttSourceConnectorTask java.lang.ArrayIndexOutOfBoundsException: Index 21 out of bounds for length 1 java.lang.ArrayIndexOutOfBoundsException: Index 21 out of bounds for length 1 at java.base/java.util.Arrays$ArrayList.get(Arrays.java:4351) at com.sintef.asam.MqttSourceConnectorTask.makeDBDoc(MqttSourceConnectorTask.java:160) at com.sintef.asam.MqttSourceConnectorTask.messageArrived(MqttSourceConnectorTask.java:126) at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:513) at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:416) at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:213) at java.base/java.lang.Thread.run(Thread.java:829)