-
Kafka消费与心跳机制(kafka 心跳机制)
1.概述 最近有同学咨询Kafka的消费和心跳机制,今天笔者将通过这篇博客来逐一介绍这些内容。 2.内容 2.1 Kafka消费 首先,我们来看看消费。Kafka提供了非常简单的消费API,使用者只需...
-
Kafka之消费与心跳(kafka消费过程)
导读kafka是一个分布式,分区的,多副本的,多订阅者的消息发布订阅系统(分布式MQ系统),可以用于搜索日志,监控日志,访问日志等。kafka是一个分布式,分区的,多副本的,多订阅者的消息发布订阅系统...
-
双十一期间Kafka以这种方式丢消息让我猝不及防(kafka丢消息可以避免吗)
讲真,我今年的双十一有点“背”,负责的Kafka集群出了一些幺蛾子,但正是这些幺蛾子,让我这个双十一过的非常充实,也让我意识到如果不体系化学习Kafka,是无法做到生产集群及时预警,将故障扼杀在摇篮中...
-
面试必问 | 聊聊Kafka的消费模型?(cnc面试必问)
大家好,我是冰河~~ 最近,有些读者去头条二面,被面试官问了一个关于Kafka的问题:多个Kafka消费者如何同时消费相同Topic下的相同Partition的数据? 看似一个简单的问题,竟然把这位读...
-
聊聊 Kafka: Consumer 源码解析之 Rebalance 机制(聊聊分手和断联背后的哲学)
一、前言 我们上一篇分析了 Consumer 如何加入 Consumer Group,其实上一篇是一个很宏观的东西,主要讲 ConsumerCoordinator 怎么与 GroupCoordinat...
-
双十一期间Kafka以这种方式丢消息让我猝不及防(kafka丢包)
讲真,我今年的双十一有点“背”,负责的Kafka集群出了一些幺蛾子,但正是这些幺蛾子,让我这个双十一过的非常充实,也让我意识到如果不体系化学习Kafka,是无法做到生产集群及时预警,将故障扼杀在摇篮中...
-
面试必问 | 聊聊Kafka的消费模型?(销售面试必问)
大家好,我是冰河~~ 最近,有些读者去头条二面,被面试官问了一个关于Kafka的问题:多个Kafka消费者如何同时消费相同Topic下的相同Partition的数据? 看似一个简单的问题,竟然把这位读...
-
聊聊 Kafka: Consumer 源码解析之 Rebalance 机制
一、前言 我们上一篇分析了 Consumer 如何加入 Consumer Group,其实上一篇是一个很宏观的东西,主要讲 ConsumerCoordinator 怎么与 GroupCoordinat...
-
灵魂发问:重复消费顺序消费分布式事务
hello大家好 我是大家的学习成长小伙伴Captain 我们继续学习RocketMQ,上一篇我们学习了广播消息、延迟消息、批量消息、过滤消息这些在RocketMQ中的特性,这一篇我们继续来学习Roc...
-
Kafka放弃Zookeeper后如何存储主题与消费组呢?(kafka中的zookeeper起到什么作用)
由于笔者公司目前使用的kafka版本是2.2.1,故当下关于kafka的内核研究目前主要是基于该版本,当然该专栏还会继续关注Kafka3.0。 我在使用kafka时发现客户端可以不依赖Zookeepe...