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

kafka msg data conversion

Browse Source
This commit is contained in:
pluto 2023-08-22 15:56:23 +08:00
parent de7b949296
commit 07307d0bef
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/data-conversion/kafka-conversation.go
View File

@ -90,7 +90,7 @@ func GetMessage() {
}(pc) }(pc)
//wg.Add(1) //wg.Add(1)
//wg.Wait() //wg.Wait()
consumer.Close()
} }
consumer.Close()
_ = <-ch _ = <-ch
} }