Go接入kafka
github.com/Shopify/sarama // kafka主要的库* github.com/bsm/sarama-cluster // kafka消费组 package producer import ( "fmt" "github.com/HappyTeemo75 ......golang中使用kafka客户端sarama消费时需要注意的一个点
kafka消费者的Consume()方法会阻塞； 当Consume()方法返回err时，不确定继续消费有没有问题；保险起见，退出进程，然后重新初始化。 当Consume()方法返回nil是，是可以 ......日志收集系统系列（三）之LogAgent
一、什么是LogAhent 类似于在linux下通过tail的方法读日志文件，将读取的内容发给kafka，这里的tailf是可以动态变化的，当配置文件发生变化时，可以通知我们程序自动 ......![]()
GO学习-(34) Go实现日志收集系统3
Go实现日志收集系统3 再次整理了一下这个日志收集系统的框，如下图 这次要实现的代码的整体逻辑为： 完整代码地址为: 高可用的分布式key-value存储，可以用 ......![]()
利用Kafka的Assign模式实现超大群组（10万+）消息推送
IM即时通信场景下，最重要的一个能力就是推送：在线的直接通过长连接网关服务转发，离线的通过APNS或者极光等系统进行推送。 本文主要是针对在线用户推送场景来进 ......![]()
Kafka入门（3）：Sarama生产者是如何工作的
在这一篇的文章中，我将从Sarama的同步生产者和异步生产者怎么创建开始讲起，然后我将向你介绍生产者中的各个参数是什么，怎么使用。 然后我将从创建生产者的代码开 ......![]()
kafka使用示例
示例代码如下： producer生产者 package main import ( "fmt" "github.com/Shopify/sarama" ) func main() { config := sarama.NewConfig() config.Produce ......日志收集系统系列（五）之LogTransfer
从kafka里面把日志取出来，写入ES,使用Kibana做可视化展示 1. ElasticSearch 1.1 介绍 Elasticsearch（ES）是一个基于Lucene构建的开源、分布式、RESTful接口的全文搜 ......![]()
日志收集系统系列（四）之LogAgent优化
实现功能 logagent根据etcd的配置创建多个tailtask logagent实现watch新配置 logagent实现新增收集任务 logagent删除新配置中没有的那个任务 logagent根据IP拉取 ......![]()
↓ 按住下拉
V2AS = Way To Ask
V2AS 一个技术分享与创造的静土
手机扫一扫
移动阅读更方便
近15日热搜文章