本文介绍 Kafka 消费的一个例子,以及如何优化提升消费的并行度。
一个例子
Kafka 消费一般使用 github.com/Shopify/sarama
包实现,现已支持消费组消费。下面是一个消费组消费的例子:
本文主要对 pika 中 Hash 数据结构的使用做一个小结。
本文介绍 golang.org/x/sync/singleflight
包的使用和原理。
自定义类型在做数据库查询和插入操作时,可以通过实现 Scanner / Valuer 接口,使我们在做db的增删查改时更加顺畅。
本文主要为了在对golang反射学习后做一个小练习,使用100行代码实现一个通用的RPC服务。