Cleaning up non used functions

broker/main.go

@@ -23,35 +23,15 @@ func SetUpKafkaConnecter() (*kafka.Conn, error) {
 	return conn, nil
 }
 
-func ProduceEvent(conn *kafka.Conn, message string) error {
-	// SetWriteDeadline sets the deadline for future Write calls and any
-	// currently-blocked Write call. Even if write times out, it may return n > 0,
-	// indicating that some of the data was successfully written. A zero value for t
-	// means Write will not time out.
-	conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
-
-	_, err := conn.WriteMessages(
-		kafka.Message{Value: []byte("one!")},
-		kafka.Message{Value: []byte("two!")},
-		kafka.Message{Value: []byte("three!")},
-	)
-	if err != nil {
-		return nil
-	}
-
-	return nil
-}
-
-func SendEventToKafka(conn *kafka.Conn, node models.Node) error {
+func SendEventToKafka(conn *kafka.Conn, node models.Node) {
 	conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
 	utils.SaveNode(&node)
 	packaged, _ := json.Marshal(node)
 	_, err := conn.WriteMessages(kafka.Message{Value: packaged})
 	if err != nil {
-		panic(err)
+		logrus.Error(err)
 	}
 
-	return nil
 }
 
 func ReadEventFromKafka() {

main.go

@@ -29,10 +29,7 @@ func main() {
 				}
 				utils.SaveNode(node)
 
-				err = broker.SendEventToKafka(Conn, *node)
-				if err != nil {
-					panic(err)
-				}
+				broker.SendEventToKafka(Conn, *node)
 			}
 
 		case err := <-errStream: