kafka msg data conversion

2 years ago · 1b439089b6
parent 9578ce4b21
commit 1b439089b6
1 changed files with 2 additions and 2 deletions
--- a/test/data-conversion/kafka-conversation.go
+++ b/test/data-conversion/kafka-conversation.go
@ -22,8 +22,8 @@ import (
 var (
 	topic = "latestMsgToRedis"
-	addr  = "127.0.0.1:9092"
+	//addr  = "127.0.0.1:9092"
-	//addr = "43.128.72.19:9092"
+	addr = "121.5.182.23:9092"
 )
 var consumer sarama.Consumer