KafkaStream快速入门

[toc] 1.1. 目标 本快速入门指南的目标是提供与KafkaStreams的第一个应用程序示例。我们将演示在你的第一个示例程序中,如果使用Kafka Str...

创建: 2023-08-22 · 更新: 2023-08-29 · xkj  | 分类:   | 访问: 1

kafka的选举机制

[toc] 1.前言: 对于整个选举算法的详情需要先了解Raft选举算法,kafka是基于该算法来实现leader选举的。有兴趣的读者可以参考之前的文章...

创建: 2023-08-22 · 更新: 2023-08-29 · xkj  | 分类:   | 访问: 1

kafka介绍及原理

[toc] 1、Kafka使用背景 在我们大量使用分布式数据库、分布式计算集群的时候,是否会遇到这样的一些问题: a.我们想分析下用户行为(pagevie...

创建: 2023-08-22 · 更新: 2024-10-13 · xkj  | 分类:   | 访问: 1

kafka命令

[toc] 注:kafka依赖zookeeper,所以启动kafka前需开启zookeeper,kafka依赖zookeeper来分发消息,并会在zo...

创建: 2023-08-22 · 更新: 2023-08-29 · xkj  | 分类:   | 访问: 1

高水位与LeaderEpoch

[toc] 前言 你可能听说过高水位,但不一定听说过Leader Epoch。前者是Kafka中非常重要的概念。而后者是0.11版本中新推出的。主要是为了...

创建: 2023-08-22 · 更新: 2023-08-29 · xkj  | 分类:   | 访问: 1

简述分区分配策略

[toc] 在kafka原理中介绍,kafka在消费组分配分区时,有两种算法: range 和 round-robin和Sticky(0.11.x版本),前两种都存...

创建: 2023-08-22 · 更新: 2024-10-13 · xkj  | 分类:   | 访问: 1

简述幂等性

[TOC] 一. 什么是幂等性? 幂等性其实是消息的一致性,分为生产者幂等性和消费者幂等性. 使用Kafka时,需要保证exactly-once语义。要知道...

创建: 2023-08-22 · 更新: 2024-10-19 · xkj  | 分类:   | 访问: 1