ConsumerGroup Kafka 消费的过程似乎大致上可以分为 ConsumerGroup 的 Rebalance 协议和 Partition 消费协议两部分，这里先看 ConsumerGroup 部分。 ConsumerGroup 的 Rebalance 是 Kafka 消费侧扩展性的体现，通过将 Partition 分配给 Consumer 实现扩展消费能力，在增加 Consumer

sarama包 基于sarama第三方库开发的 kafka client,往kafka里面发送消息 package mainimport ("fmt""github.com/Shopify/sarama""math/rand""strconv")//基于sarama第三方库开发的 kafka client,往kafka里面发送消息func main() {//1.生产者配置config :=

启动kafka 分别命令行启动zookeeper和kafka .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties.\bin\windows\kafka-server-start.bat .\config\server.properties  producer import ("fmt""github

埋点日志解决方案——Golang+Gin+Sarama VS Java+SpringCloudGateway+ReactorKafka 之前我就写过几篇OpenResty+lua-kafka-client将埋点数据写入Kafka的文章，如下： Lua将Nginx请求数据写入Kafka——埋点日志解决方案 python定时任务执行shell脚本切割Nginx日志-慎用 nginx+lua写入