fix: don't panic if record received by fluentbit is invalid

Signed-off-by: Lukas Wöhrl <[email protected]>

Author: woehrl01

input/encoder.go

@@ -15,7 +15,6 @@
 //  limitations under the License.
 //
 
-
 package input
 
 import (

output/decoder.go

@@ -85,7 +85,10 @@ func GetRecord(dec *FLBDecoder) (ret int, ts interface{}, rec map[interface{}]in
 	t := slice.Index(0).Interface()
 	data := slice.Index(1)
 
-	map_data := data.Interface().(map[interface{}]interface{})
+	map_data, ok := data.Interface().(map[interface{}]interface{})
+	if !ok {
+		return -3, 0, nil
+	}
 
 	return 0, t, map_data
 }