1426919587
Results
3
comments of
1426919587
> 对于 ConsumeHandle func(key, value string) error 一般从kafka接收的消息都是json，为什么要做类型转换呢 json也是string也是[]byte
> > 感谢对`kafka-go`进行服务化封装，的确用起来更简单了！ > > 我对消费代码有个疑惑，望解答： > > ``` > > for i := 0; i < q.c.Processors; i++ { > > q.consumerRoutines.Run(func() { > > for msg := range...
> > > > 感谢对`kafka-go`进行服务化封装，的确用起来更简单了！ > > > > 我对消费代码有个疑惑，望解答： > > > > ``` > > > > for i := 0; i < q.c.Processors; i++ { > >...