kafka
-
Kafka-服务端-PartitionLeaderSelector、ReplicaStateMachine
PartitionLeaderSelector 通过对前面的分析可知,PartitionMachine将Leader副本选举、确定ISR集合的工作委托给了PartitionLead…
-
Kafka
目录 1、Kafka简要描述 1.1、kafka 1.2 消息队列 1.3、为什么需要消息队列 1.4 kafka架构 1.5 分布式模型 1.6 Kafka网址 2、Kafka集…
-
「查缺补漏」 Kafka 核心知识梳理
这篇文章干货很多,希望你可以耐心读完。 Kafka 基础知识15问 Kafka 是什么, 适应场景有哪些? Kafka 是一个分布式的流式处理平台,用于实时构建流处理应用。主要应用…
-
【Kafka每日一问】kafka三种压缩方式差别?
Kafka 提供了三种压缩算法,分别是GZIP、Snappy 和 LZ4。 这三种压缩算法的差异主要在以下方面: 压缩比:GZIP 压缩比最高,DEFLATE 算法,但压缩和解压缩…
-
Kafka延迟队列的实现方式
在现代的分布式系统中,延迟队列是一种常见的解决方案,用于处理具有延迟要求的任务或消息。Apache Kafka是一个高性能、可扩展的分布式消息队列,可以作为延迟队列的基础设施。本文…
-
Helm方式部署 zookeeper+kafka 集群 ——2023.05
文章目录 版本概况 一、添加helm仓库 二、安装部署集群 2.1 在线安装zookeeper+kafka集群 2.2 离线安装zookeeper+kafka集群 三、验证kafk…
-
【kafka性能测试脚本详解、性能测试、性能分析与性能调优】
Kafka 性能测试 一、介绍 Apache Kafka 官方提供了两个客户端性能测试脚本,它们的存放位置如下: 生产者性能测试脚本:$KAFKA_HOME/bin/kafka-p…
-
【flink番外篇】16、DataStream 和 Table 相互转换示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
60道KafKa高频题整理(附答案背诵版)
废话不多说,直接上干货 简述什么是 Kafka 的 Topic ? Kafka 的 Topic 是一个存储消息的逻辑概念,可以认为是一个消息集合。每条消息发送到 Kafka 集群的…
-
Linux——kafka常用命令
一、前言 多多点赞,会变好看! 多多留言,会变有钱! 二、Kafka的常用命令包括: 1. 启动Zookeeper服务 前台启动: ./bin/zookeeper-server-s…
-
Kafka学习笔记三(生成数据发送与分区)
Kafka学习笔记三(生成数据发送与分区) Kafka的消息从生产者到集群总共分为两个线程 一个是main,一个是sender main 线程用于把消息放到 RecordAccum…
-
【Spring连载】使用Spring访问 Apache Kafka(二十一)—-提示,技巧和例子
【Spring连载】使用Spring访问 Apache Kafka(二十一)—-提示,技巧和例子Tips, Tricks and Examples 一、手动分配所有分区…
-
Kafka【应用 01】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试(一篇学会使用 Offset Explorer)
1.The Ultimate UI Tool for Kafka 官方自称 Offset Explorer 是 Kafka 的终极 UI 工具 😄 我们看一下 官网…
-
Kafka的监控和报警机制
Kafka的监控和报警机制是保证Kafka集群的稳定和可靠运行的重要组成部分。本文将详细介绍Kafka的监控和报警机制,包括监控指标、监控工具、报警配置和报警策略等。 1. 监控指…
-
【SpringBoot系列】SpringBoot整合Kafka(含源码)
文章目录 前言 什么是Kafka? Kafka的应用场景? 日志收集: 消息系统: 用户活动跟踪: 指标和日志聚合: 事件源: 示例 版本依赖 代码 KafkaConfig Kaf…
