kafka msg data conversion

2 years ago · aafe633726
parent af6608a7c8
commit aafe633726
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"
+	topic = "ws2ms_chat"
 	addr  = "127.0.0.1:9092"
 	//addr = "43.128.72.19:9092"
 )