test: remove topic check

Author: phi

test/helper.go

@@ -67,27 +67,25 @@ func consumeKafkaMessage(consumer *kafka.Consumer, topic string) bool {
 		log.Fatalln(err)
 		return false
 	}
-	for {
-		timer := time.NewTimer(time.Second * 5)
-		c := make(chan string)
-		go func() {
+	timer := time.NewTimer(time.Second * 10)
+	c := make(chan string)
+	go func() {
+		for {
 			_, err := consumer.ReadMessage(100 * time.Millisecond)
 			if err == nil {
 				if err != nil {
 					fmt.Printf("Failed to deserialize payload: %s\n", err)
 				} else {
 					c <- "success"
-					return
 				}
 			}
-		}()
-		select {
-		case <-c:
-			return true
-		case <-timer.C:
-			return false
 		}
-
+	}()
+	select {
+	case <-c:
+		return true
+	case <-timer.C:
+		return false
 	}
 }