ERROR Unable to process record SinkRecord

Yes that is the data - although the developer of the Producer has agreed to write as JSON - I’ll see what it looks like in the next couple of days …Errors on adapter startup · Issue #6 · tim-hellhake/kafka-bridge · GitHub

The current structure is :
topic: device id
message key: property name
message value: {[property name]: [property value]}.

The plan is to use MongoDB as the persistence for all telemetry - I’ll then be wanting to visualise the data and perform analytics - haven’t chosen any toolsets as yet for this.