kafka-mqtt-source-connector icon indicating copy to clipboard operation
kafka-mqtt-source-connector copied to clipboard

Array out of bounds error

Open gavinheale opened this issue 9 months ago • 3 comments

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)

gavinheale avatar Sep 19 '23 18:09 gavinheale