blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-13 16:47:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

tools for conversion

Browse Source
This commit is contained in:
pluto 2023-08-23 16:52:56 +08:00
parent 37d9b18fb6
commit 70c43f9b77
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tools/data-conversion/kafka-conversation.go
View File

@ -106,11 +106,12 @@ func GetMessage() {
msgFromMQ := &sdkws.MsgData{} msgFromMQ := &sdkws.MsgData{}
err := proto.Unmarshal(msg.Value, msgFromMQ) err := proto.Unmarshal(msg.Value, msgFromMQ)
if err != nil { if err != nil {
fmt.Printf("err:%s", err) fmt.Printf("err:%s \n", err)
} }
fmt.Printf("msg:%s", msgFromMQ) fmt.Printf("msg:%s \n", msgFromMQ)
//fmt.Printf("Partition:%d, Offset:%d, Key:%s, Value:%s\n", msg.Partition, msg.Offset, string(msg.Key), string(msg.Value)) //fmt.Printf("Partition:%d, Offset:%d, Key:%s, Value:%s\n", msg.Partition, msg.Offset, string(msg.Key), string(msg.Value))
} }
}(pc) }(pc)
} }