对于kafka消费者来说，最重要的事情就是监控它们的消费进度了，或者说是监控它们消费的滞后程度。这个滞后程度有个专门的名称：消费者Lag或Consumer Lag。 所谓滞后程度，就是指消 ...

压缩的是使用时间换空间的思想，具体来说就是使用CPU的时间去换取空间或网络I/0传输量。 怎么压缩？ kafka是如何压缩的消息的呢？目前，kafka共有俩大消息格式，社区分别称之 ...

消费组，即Consumer Group ,应该算是kafka比较有创意的设计了。那么何谓ConsumerGroup呢？用一句话概括就是：ConsumerGroup是kafka提供的可扩展且具有容错 ...

1.为什么分区 kafka有主题（Topic）的概念，它是承载真实数据的逻辑容器，而在主题之下还分为若干个分区，也就是说kafka的消息组织方式实际上是三级结构： 主题---分区---消息 ...

所谓的副本机制（Replication）,也可以称之为备份机制，通常是指分布式系统在多台互联网的机器上保存相同的数据拷贝。副本机制有什么好处么？ 提供数据冗余：即使系统部分组件失效，系统 ...