From 17e18fcab6a95230fa856264a58a733a8dfddd15 Mon Sep 17 00:00:00 2001
From: Camden Cheek <camden@ccheek.com>
Date: Fri, 17 Jul 2020 17:22:00 -0400
Subject: [PATCH] Make journald emit map[string]interface{}

---
 plugin/builtin/input/journald.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/plugin/builtin/input/journald.go b/plugin/builtin/input/journald.go
index 34e2ba4f9..91381f794 100644
--- a/plugin/builtin/input/journald.go
+++ b/plugin/builtin/input/journald.go
@@ -162,7 +162,7 @@ func (plugin *JournaldInput) Start() error {
 }
 
 func (plugin *JournaldInput) parseJournalEntry(line []byte) (*entry.Entry, string, error) {
-	var record map[string]string
+	var record map[string]interface{}
 	err := plugin.json.Unmarshal(line, &record)
 	if err != nil {
 		return nil, "", err
@@ -173,7 +173,7 @@ func (plugin *JournaldInput) parseJournalEntry(line []byte) (*entry.Entry, strin
 		return nil, "", errors.New("journald record missing __REALTIME_TIMESTAMP field")
 	}
 
-	timestampInt, err := strconv.ParseInt(timestamp, 10, 64)
+	timestampInt, err := strconv.ParseInt(timestamp.(string), 10, 64)
 	if err != nil {
 		return nil, "", fmt.Errorf("parse timestamp: %s", err)
 	}
@@ -187,7 +187,7 @@ func (plugin *JournaldInput) parseJournalEntry(line []byte) (*entry.Entry, strin
 
 	entry := plugin.NewEntry(record)
 	entry.Timestamp = time.Unix(0, timestampInt*1000) // in microseconds
-	return entry, cursor, nil
+	return entry, cursor.(string), nil
 }
 
 func (plugin *JournaldInput) syncOffsets() {