kafka msg data conversion

2 years ago · 6cd8226098
parent b4d7b9c50c
commit 6cd8226098
1 changed files with 1 additions and 1 deletions
--- a/test/data-conversion/kafka-conversation.go
+++ b/test/data-conversion/kafka-conversation.go
@ -90,7 +90,7 @@ func GetMessage() {
 		}(pc)
 		//wg.Add(1)
 		//wg.Wait()
-		consumer.Close()
 	}
+	consumer.Close()
 	_ = <-ch
 }