Remove error management as it break on empty values
This commit is contained in:
parent
7cbb7e9180
commit
2a04e01457
|
@ -52,10 +52,7 @@ func ReadEventFromKafka() {
|
|||
|
||||
var node models.Node
|
||||
|
||||
err = json.Unmarshal(m.Value, &node)
|
||||
if err != nil {
|
||||
logrus.Error("error unmarshalling kafka object:", err)
|
||||
}
|
||||
json.Unmarshal(m.Value, &node)
|
||||
|
||||
utils.SaveNode(&node)
|
||||
|
||||
|
|
Loading…
Reference in a new issue