import "github.com/Shopify/sarama" 　　saram 使用纯go语言编写。用于处理Apache Kafka（0.8及更高版本）的纯Go客户端库. 它包括一个易于生成和使用消息的高级API，以及一个在高级API不足时控制线路上字节的低级API. 内嵌提供 ...

go语言操作kafka Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据，具有高性能、持久化、多副本备份、横向扩展等特点。本文介绍了如何使用Go语言发送和接收kafka消息。 sarama Go语言中连接kafka使用第三方库 ...

go操作kafka Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据，具有高性能、持久化、多副本备份、横向扩展等特点。本文介绍了如何使用Go语言发送和接收kafka消息。 sarama Go语言中连接kafka使用第三方库 ...

1）包的选择 confluent-kafka-go使用了rdkafka的c库，破坏了go代码的收敛，不使用； sarama不支持groud id 的功能，写consumer需要自己管理消费的partition，offset；很难用； sarama-cluster是对sarama的一层封装 ...

在以前的文章kafka初探go和C#的实现里面我们用了sarama来消费kafka的消息，但是很遗憾它没有group的概念。没办法 我们只能用sarama-cluster来实现， 注意sarama版本不要太新否则有错误panic: non-positive interval ...

简单测试 环境：Centos6.4，PHP7，kafka服务器IP：192.168.9.154，PHP服务器:192.168.9.157 在192.168.9.157创建目录和文件。 记住消费者PHP文件要在终端运行:php consumer.php ...

1.Kafka相关知识 Broker：即Kafka的服务器，用户存储消息，Kafa集群中的一台或多台服务器统称为broker。 Message消息：是通信的基本单位，每个 producer 可以向一个 topic（主题）发布一些消息 ...

针对golang的 kafka client 有很多开源package，例如sarama, confluent等等。在使用sarama 包时，高并发中偶尔遇到crash。于是改用confluent-kafka-go，其简单易用，并且表现稳定。 本文主要介绍 ...