Revert local changes

filebeat/filebeat.yml

@@ -11,9 +11,7 @@
 # configuration file.
 
 #=========================== Filebeat inputs =============================
-logging.level: debug
-filebeat.overwrite_pipelines: true
-setup.ilm.enabled: false
+
 filebeat.inputs:
 
 # Each - is an input. Most options can be set at the input level, so

filebeat/input/kafka/input.go

@@ -348,9 +348,8 @@ func (h *groupHandler) parseMultipleMessages(bMessage []byte) []string {
 		for _, ms := range obj[h.expandEventListFromField] {
 			js, err := json.Marshal(ms)
 			if err == nil {
-				messages = append(messages, string(js))
-			}else {
 				h.log.Errorw(fmt.Sprintf("Kafka serializing message %s", ms), "error", err)
+				messages = append(messages, string(js))
 			}
 		}
 	}