diff --git a/tools/data-conversion/kafka-conversation.go b/tools/data-conversion/kafka-conversation.go index d1fd72fa3..6fc655c9e 100644 --- a/tools/data-conversion/kafka-conversation.go +++ b/tools/data-conversion/kafka-conversation.go @@ -33,8 +33,8 @@ import ( var ( topic = "ws2ms_chat" - //addr = "127.0.0.1:9092" - addr = "43.128.72.19:9092" + addr = "127.0.0.1:9092" + //addr = "43.128.72.19:9092" ) const (