go-queue
go-queue copied to clipboard
为什么要将收到的消息转换为string
对于 ConsumeHandle func(key, value string) error 一般从kafka接收的消息都是json,为什么要做类型转换呢
对于 ConsumeHandle func(key, value string) error 一般从kafka接收的消息都是json,为什么要做类型转换呢
json也是string也是[]byte