这一讲，我们接着介绍下sarama kafka client的消费者的实现，先从例子开始：

https://github.com/Shopify/sarama 是一个纯go实现的kafka客户端，是gopher学习kafka一个很好的资料。说实话sarama的代码组织很烂，密密麻麻一堆源码文件都在一个目录，让人无从下手，下面列出了一部分：...

confluent-kafka-go是已知的kafka 客户端中最快的，为什么呢？因为它非常轻量，通过cgo 对librdkafka做了一个封装，所以本质上运行的是一个c客户端。

在高并发情况下的秒杀优化，我们知道当并发数达到一定量的时候，会对数据库服务器带来很大的压力，那么如何缓解这些压力以及提高并发的QPS就是整个项目的解决重点，也是我们优化系统的目标。...

cat_id smallint unsigned not null auto_increment primary key comment'类别ID',

不知道大家有没有遇到这样的场景，就是一个项目中要消费多个kafka消息，不同的消费者消费指定kafka消息。遇到这种场景，我们可以通过kafka的提供的api进行配置即可。但很多时候我们会使用spring-kafka来简化开发，可是spring...

kafka可以以来zookeeper进行，最新版本kafka已经不需要额外再安装zookeeper了，它可以自己存储元数据信息了。kafka的核心概念Broker 消息中间件处理节点（服务器），一个节点就是一个broker，一个Kafka集群由一个或多个broker组...

Service 不是一个单独的进程，它和应用程序在同一个进程中，Service 也不是一个线程,它和线程没有任何关系，所以它不能直接处理耗时操作。如果直接把耗时操作放在 Service 的 onStartCommand() 中，很容易引起 ANR（ActivityMa...

在上一篇文章中，我们通过一个网上商店的示例程序学习了如何使用Opentracing在Istio服务网格中传递分布式调用跟踪的上下文，以及如何将方法级的调用信息加入到Istio/Envoy生成的调用链中。采用Opentracing可以减少应用代...

In the previous post, we discussed how to use Opentracing to help Istio Service Mesh to propagate tracing context across process boundaries, and how to enrich I...