Only saving objects that have an ID

broker/main.go

@@ -3,6 +3,7 @@ package broker
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"time"
 
 	"github.com/segmentio/kafka-go"
@@ -51,11 +52,10 @@ func ReadEventFromKafka() {
 		}
 
 		var node models.Node
-
 		json.Unmarshal(m.Value, &node)
-
-		utils.SaveNode(&node)
-
+		if len(node.ID) != 0 {
+			fmt.Println(node)
+			utils.SaveNode(&node)
+		}
 	}
-
 }

main.go

@@ -28,7 +28,6 @@ func main() {
 				if err != nil {
 					panic(err)
 				}
-				utils.SaveNode(node)
 				broker.SendEventToKafka(Conn, *node)
 			}
 
@@ -37,5 +36,3 @@ func main() {
 		}
 	}
 }
-
-// Helpers