{"log.level":"info","@timestamp":"2023-02-21T20:03:45.695Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":41},"message":"This is mqtt-kafka-bridge build date: 2023-02-16 14:29:15","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:45.695Z","log.origin":{"file.name":"internal/fgtrace.go","file.line":16},"message":"DEBUG_ENABLE_FGTRACE not set. Not enabling debug tracing","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:45.709Z","log.origin":{"file.name":"mqtt-kafka-bridge/mqtt.go","file.line":145},"message":"Running in normal mode (ia/#) (USE_TLS) (united-manufacturing-hub-mqttkafkabridge-7d888f7dfb-dlfn2)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:48.536Z","log.origin":{"file.name":"mqtt-kafka-bridge/mqtt.go","file.line":103},"message":"Connected to MQTT broker (united-manufacturing-hub-mqttkafkabridge-7d888f7dfb-dlfn2)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:48.828Z","log.origin":{"file.name":"mqtt-kafka-bridge/mqtt.go","file.line":165},"message":"MQTT subscribed (ia/#)","ecs.version":"1.6.0"}
%4|1677009828.834|CONFWARN|rdkafka#producer-2| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance
%4|1677009828.846|CONFWARN|rdkafka#producer-3| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance
{"log.level":"info","@timestamp":"2023-02-21T20:03:48.850Z","log.origin":{"file.name":"mqtt-kafka-bridge/kafka.go","file.line":78},"message":"Starting Kafka consumer for topic: ^ia.+","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:48.850Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 0.000000| Produced Kafka messages/s: 0.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 0/100000","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:53.850Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 3.000000| Produced Kafka messages/s: 0.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:03:58.851Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 3.000000| Produced Kafka messages/s: 0.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:03.852Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 3.000000| Produced Kafka messages/s: 0.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:08.853Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 3.000000| Produced Kafka messages/s: 0.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:13.853Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 3.000000| Produced Kafka messages/s: 0.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:18.854Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 3.000000| Produced Kafka messages/s: 0.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 0/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:23.818Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:23.855Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 1| Kafka->MQTT queue length: 0| Produced Kafka messages: 6.000000| Produced Kafka messages/s: 0.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 4/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:23.937Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:24.823Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:44 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:24.882Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:25.819Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:25.930Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:26.814Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:26.882Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:27.835Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:27.929Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:28.818Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:28.855Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 3| Kafka->MQTT queue length: 0| Produced Kafka messages: 19.000000| Produced Kafka messages/s: 2.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 19/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:28.927Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:29.813Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:29.880Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:30.806Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:30.889Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:31.807Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:31.926Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:32.816Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:45 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:32.925Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:33.815Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:47 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:33.856Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 29.000000| Produced Kafka messages/s: 2.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 26/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:33.881Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:34.816Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:34.931Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:35.810Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:35.891Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:36.819Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:36.898Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:37.810Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:37.887Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:38.819Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:38.857Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 37.000000| Produced Kafka messages/s: 1.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 34/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:38.895Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:192]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:39.812Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:39.885Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:40.819Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:40.931Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:41.822Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:41.906Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:42.821Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:44 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:42.931Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:43.826Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:44 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:43.858Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 1| Kafka->MQTT queue length: 0| Produced Kafka messages: 53.000000| Produced Kafka messages/s: 3.200000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 51/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:43.897Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:44.822Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:44.898Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:45.815Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:45.899Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:46.823Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:46.934Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:47.821Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:43 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:47.892Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:48.821Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:47 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:48.858Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 72.000000| Produced Kafka messages/s: 3.800000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 69/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:48.901Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:49.827Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:43 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:49.927Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:50.825Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:50.901Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:51.826Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:51.931Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:52.823Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:45 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:52.925Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:53.825Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:53.860Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 88.000000| Produced Kafka messages/s: 3.200000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 85/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:53.926Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:256]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:54.826Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:37 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:54.902Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:55.821Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:55.914Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:256]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:56.826Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:56.924Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:57.826Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:57.904Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:58.827Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:04:58.861Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 99.000000| Produced Kafka messages/s: 2.200000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 96/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:58.904Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:59.827Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:04:59.903Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:00.825Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:00.908Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:01.826Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:01.928Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:02.827Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:02.906Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:272]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:03.825Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:03.861Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 107.000000| Produced Kafka messages/s: 1.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 104/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:03.918Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:256]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:04.829Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:36 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:04.905Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:05.830Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:05.906Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:256]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:06.831Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:06.926Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:07.824Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:07.906Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:08.843Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:08.862Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 3| Kafka->MQTT queue length: 0| Produced Kafka messages: 119.000000| Produced Kafka messages/s: 2.400000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 119/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:08.933Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:09.831Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:09.903Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:10.835Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:45 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:10.907Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:11.837Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:11.899Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:192]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:12.855Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:12.905Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:13.837Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:43 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:13.862Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 3| Kafka->MQTT queue length: 0| Produced Kafka messages: 134.000000| Produced Kafka messages/s: 3.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 134/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:13.912Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:14.838Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:45 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:14.909Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:15.833Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:47 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:15.909Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:16.838Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:35 Word18:65283 Word2:64512 Word4:1 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:16.924Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:17.839Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:36 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:17.911Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:18.836Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:18.863Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 148.000000| Produced Kafka messages/s: 2.800000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 145/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:18.927Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:19.837Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:19.906Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:20.839Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:37 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:20.926Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:21.837Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:21.906Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:22.841Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:22.932Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:23.842Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:23.863Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 158.000000| Produced Kafka messages/s: 2.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 155/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:23.910Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:24.839Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:24.911Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:25.837Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:25.911Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:26.847Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:26.909Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:27.846Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:27.925Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:28.837Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:28.864Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 166.000000| Produced Kafka messages/s: 1.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 163/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:28.901Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:29.844Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:29.909Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:208]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:30.846Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:30.909Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:31.841Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:31.925Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:32.839Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:32.912Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:33.849Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:36 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:33.865Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 171.000000| Produced Kafka messages/s: 1.000000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 174/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:33.925Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:34.848Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:38 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:34.910Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:35.838Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:44 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:35.903Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:36.847Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:36.911Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:37.850Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:45 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:37.909Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:192]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:38.845Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:38.866Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 1| Kafka->MQTT queue length: 0| Produced Kafka messages: 184.000000| Produced Kafka messages/s: 2.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 182/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:38.912Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:39.846Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:39.926Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:40.843Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:43 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:40.911Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:41.846Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:41.914Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:42.848Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:42.912Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:43.845Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:42 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:43.866Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 196.000000| Produced Kafka messages/s: 2.400000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 193/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:43.925Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:44.846Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:45 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:44.911Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:45.847Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:41 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:45.927Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:46.842Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:40 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:46.905Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:224]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:47.850Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:37 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:47.912Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:48.846Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:0 Word10:65280 Word12:223 Word14:65280 Word16:39 Word18:65283 Word2:64512 Word4:2 Word6:65280 Word8:0]] (ia.sensordatas.port1)","ecs.version":"1.6.0"}
{"log.level":"info","@timestamp":"2023-02-21T20:05:48.867Z","log.origin":{"file.name":"mqtt-kafka-bridge/main.go","file.line":279},"message":"Reporting stats| MQTT->Kafka queue length: 0| Kafka->MQTT queue length: 0| Produced Kafka messages: 209.000000| Produced Kafka messages/s: 2.600000| Produced MQTT messages: 0| Produced MQTT messages/s: 0.000000| Message LRU size: 206/100000| Raw Message LRU size: 3/100000","ecs.version":"1.6.0"}
{"log.level":"error","@timestamp":"2023-02-21T20:05:48.923Z","log.origin":{"file.name":"mqtt-kafka-bridge/hash.go","file.line":52},"message":"Error parsing message: no timestamp [map[Word0:240]] (ia.sensordatas.port2)","ecs.version":"1.6.0"}