diff --git a/main.go b/main.go
index 0beac65..60c5280 100644
--- a/main.go
+++ b/main.go
@@ -16,10 +16,10 @@ func main() {
 	// The false flag specifies that we want heartbeat messages.
 	stream, errStream := certstream.CertStreamEventStream(false)
 	fmt.Println("Starting to get data from CertStream...")
-	Conn, err := broker.SetUpKafkaConnecter()
-	if err != nil {
-		panic(err)
-	}
+	// Conn, err := broker.SetUpKafkaConnecter()
+	// if err != nil {
+	// panic(err)
+	// }
 
 	// stop channel
 	stopChan := make(chan os.Signal)
diff --git a/models/main.go b/models/main.go
index 04181eb..4a6b307 100644
--- a/models/main.go
+++ b/models/main.go
@@ -26,6 +26,7 @@ func BuildNode(flag string, dataType string, data string) *Node {
 // BuildCertNode builds a custom node based on CertStream.
 func BuildCertNode(rawNode *CertStreamWrapper) *CertNode {
 	return &CertNode{
+		ID:               "certstream--" + uuid.New().String(),
 		Fingerprint:      rawNode.Data.Data.LeafCert.Fingerprint,
 		NotBefore:        time.Unix(int64(rawNode.Data.Data.LeafCert.NotBefore), 0).Format(time.RFC3339),
 		NotAfter:         time.Unix(int64(rawNode.Data.Data.LeafCert.NotAfter), 0).Format(time.RFC3339),