kafka msg data conversion

2 years ago · 3c97d57d9d
parent 7d92a45037
commit 3c97d57d9d
1 changed files with 1 additions and 1 deletions
--- a/test/data-conversion/kafka-conversation.go
+++ b/test/data-conversion/kafka-conversation.go
@ -21,7 +21,7 @@ import (

 var (
 	topic = "latestMsgToRedis"
-	addr  = "43.128.72.19:9092"
+	addr  = "127.0.0.1:9092"
 )

 var consumer sarama.Consumer