1. 前言  起源是某个客户线上环境的一次OOM，据说这种诡异的OOM曾经第二次了。首先形容一下OOM的相干信息：堆内存13G；应用G1垃圾收集器；OOM后主动生成…

有时候因为特定的业务须要,咱们的kafka分区的磁盘可能不够,这个时候咱们须要本身删除磁盘数据或者应用脚本定时检测删除生产完的磁盘数据。然而有一个重要的点…

在现在的分布式环境时代，任何一款中间件产品，大多都有一套机制去保障一致性的，Kafka 作为一个商业级消息中间件，音讯一致性的重要性可想而知，那 Kafka 如…

正本迁徙是Kafka最高频的操作，对于一个领有几十万个正本的集群，通过人工去实现正本迁徙是一件很艰难的事件。Cruise Control作为Kafka的运维工具，它蕴含了K…

在我的项目中应用到了Kafka作为音讯队列中间件以同步容器状态，然而对于为什么应用Kafka，以及与其余的音讯队列中间件有什么区别不甚了解，因而撰写此文，作为日…

在现在的分布式环境时代，任何一款中间件产品，大多都有一套机制去保障高可用的，Kafka 作为一个商业级消息中间件，音讯可靠性的重要性可想而知，那 Kafka 如…

简介：Delta Lake是一个开源存储层，它为数据湖带来了可靠性。Delta Lake提供了ACID事务、可扩大的元数据处理，并对立了流式解决和批处理数据处理。Delta-Lak…

一、前言上一篇咱们讲了 聊聊 Kafka：Kafka 音讯失落的场景以及最佳实际，这一篇咱们来说一说 Kafka 音讯反复的场景以及最佳实际。咱们上面会从以下两个方面…

ConsumerCoordinator是协调器，如果同一个group进行生产的时候，须要进行协调，这里和rocketmq不同，rocketmq是消费者本人来协调的（RocketMQ — 写在音讯拉…

大家好，我是老周，有快二十多天没有更新文章了，很多小伙伴始终在催更。先阐明下最近的状况，最近我的项目上线很忙，没有工夫写，并且组里有个共事应用 Kafka 不…