PHP 消息队列 Kafka 使用

安装 Kafka 服务 直接到 kafka 官网 , 下载最新的 wget https://mirror.bi…

Kafka 异步消息也会阻塞?记一次 Dubbo 频繁超时排查过程

线上某服务 A 调用服务 B 接口完成一次交易,一次晚上的生产变更之后,系统监控发现服务 B 接口频繁超时,后续甚至返回线程池耗尽错误 Thread pool is EXHAUSTED。

Kafka性能分析利器!Linux系统PageCache缓存命中率工具

日常工作中对IO密集型服务进行性能调优时,一个常见的问题就是:“is Linux caching my data or not?”。缓存是现在所有高并发系统必需的核心模块,主要作用就是把经常访问的数据,提前读入到内存中。

玩转Kafka的生产者——分区器与多线程

1 // 连接配置 2 private static final String ZK_CONNECT = “10.0.90.53:2181”; 3 4 // session过期时间 5 private static final int SEESSION_TIMEOUT = 30

Kafka元数据在zookeeper中的存储分布

我们都知道,自从Kafka诞生之际,就一直使用Zookeeper服务来进行kafka集群的元数据和状态管理,虽然在 KIP-500 中有提议未来将移除Zookeeper的依赖,使用Raft协议来实现新的元数据和状态管理,但在这之前,我们仍然需要对kafka集群的整个元数据和状态有

真的,关于 Kafka 入门看这一篇就够了

作者 | cxuan责编 | 刘静Kafka 系列的阶段性总结(万字长文,做好准备,建议先收藏再看)初识 Kafka什么是 KafkaKafka 是由 Linkedin 公司开发的,它是一个分布式的,支持多分区、多副本,基于 Zookeeper 的分布式消息流平台,它同时也是一款

技术干货总结:Kafka无消息丢失

技术干货总结:Kafka无消息丢失

技术面试官问:Kafka为什么速度那么快?解答如下(建议收藏)

一般认为在磁盘上读写数据是会降低性能的,因为寻址会比较消耗时间,但是实际上,Kafka的特性之一就是高吞吐率。

大数据入门:Kafka基础讲解

Kafka框架,在大数据生态当中,以作为消息总线使用闻名,尤其是实时数据流消息场景下,Kafka可以说是名气响当当。

Kafka消费者的使用和原理

这周我们学习下消费者,还是先从一个消费者的Hello World学起:前两步和生产者类似,配置参数然后根据参数创建实例,区别在于消费者使用的是反序列化器,以及多了一个必填参数 group.id,用于指定消费者所属的消费组。