Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。该项目的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。
近年来，国内多个城市的存量房市场呈现出波动频繁、挂牌量上升但成交周期拉长的结构性特征。特别是在一线与强二线城市中，房源更新节奏加快，用户浏览行为活跃，价格异动更...
腾讯云TDP ｜ 产品KOL (已认证)
首先是 node.id，这个我理解和 broker.id 差不多，但是zk模式的 kafka 集群中，节点被称为broker，但是在 Kraft 模式下，每个节...
最近还没摸鱼几天呢，领导又给安排任务了，让我研究一下 Debezium 做一下数据库的 CDC 采集。Debezium？第一个念头就是好熟悉的名字，这不是两年前...
作者介绍：简历上没有一个精通的运维工程师。下面的思维导图也是预计更新的内容和当前进度(不定时更新)。
Kafka是一个高性能的分布式流处理平台，专为实时数据处理、流数据分发和海量消息处理设计，广泛应用于日志收集、实时分析和事件驱动架构等领域。其核心在于通过生产者...
Kafka 的开源版本支持一个用于辅助 Partition 重新分配的工具，称为?Kafka-reassign-partitions（Bin/kafka-rea...
（2）由于脚本设置了全局变量，执行需要使用 ==source xxx.sh== 命令。
Zookeeper 安装文件为apache-zookeeper-3.6.2-bin.tar.gz脚本内容如下：
分布式是指将计算任务分散到多个计算节点上进行并行处理的一种计算模型。在分布式系统中，多台计算机通过网络互联，共同协作完成任务。每个计算节点都可以独立运行，并且可...
采用golang生态的 wails 进行开发，支持windows，macos，linux等多平台
笔记梳理2.0版本到4.0版本之间的差异，发现修复代码很独立，并不存在与别的模块耦合的情况。建议有需要修复的朋友可以自行修改自己对应Kafka版本的源码编译、更...
我们前面演示都是依赖ZooKeeper的版本，本小节我们介绍2个版本不依赖ZooKeeper的版本，第一个版本就是我们前面使用的版本：kafka_2.13-2....
使用kafka自带的zookeeper，首先将zookeeper启动之后，在启动kafka的时候，报下面的异常，如下所示：
生产者通过批量压缩后再批量发送的方式，将一批消息作为一个整体（“批消息”）提交给?broker?处理。broker?会直接对这一批消息进行分发、复制、刷盘等操作...
在《5 分钟了解 kafka 核心概念》中笔者对消费者和消费者组均进行了概念解释，为了更高的解释?kafka?分区分配策略，笔者下面会通过几张图来先引入分区分配...
在 Kafka 中，消费者在订阅主题时，可以选择?subscribe?或?assign?两种方法。两者的主要区别在于?消费者的分区分配?和?使用场景。下面是它们...
Kafka 是一个分布式流平台，广泛应用于大规模实时数据流的处理。它的核心概念可以帮助我们理解其运作方式。本文将以简明的方式介绍 Kafka 的几个关键概念，帮...
从上面的表中看到，kafka 目前是 7 个大版本，但是实际上还有 2.x 和 3.x 系列两个版本，下面这张图是 kafka 不同版本的演进情况
一般情况下，我们的分区很少会出现异常的情况，但是在Broker异常下线，尤其是一次性下线多个节点的情况就会出现。我这里为了演示，所以把上个小节5节点Kafka直...
