mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-12-11 23:47:32 +08:00
kafka msg data conversion
This commit is contained in:
parent
1610a410ae
commit
183ee60620
@ -21,7 +21,7 @@ import (
|
||||
|
||||
var (
|
||||
topic = "latestMsgToRedis"
|
||||
addr = "43.128.72.19:9092"
|
||||
addr = "127.0.0.1:9092"
|
||||
)
|
||||
|
||||
var consumer sarama.Consumer
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user