kafka
-
Kafka – 消费进度监控（Consumer Lag）
所谓滞后程度，就是指消费者当前落后于生产者的程度。 Lag 应该算是最最重要的监控指标了。它直接反映了一个消费者的运行情况。一个正常工作的消费者，它的 Lag 值应该很小，甚至是接…
-
【flink番外篇】21、Flink 通过SQL client 和 table api注册catalog示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Kafka 消费者如何实现消费者组内分区平衡，Kafka常见问题
1、简介 一个消费者组中有多个consumer组成，一个topic有多个partition组成，现在的问题是，到底由哪个consumer来消费哪个partition…
-
kafka实战-消费者offset重置问题
kafka实战-消费者offset重置问题 背景 问题现象 分析原因 问题解决 附-常见的消费者配置描述和调优方案 1. max.poll.records 2. fetch.max…
-
CMAK Kafka可视化管理工具
CMAK简介 为了简化开发者和服务工程师维护Kafka集群的工作，yahoo构建了一个叫做Kafka管理器的基于Web工具，叫做 CMAK（原名Kafka Manager）。 这个…
-
提炼设计框架，一文搞懂Redis/MySQL/Kafka为什么这样设计
大家好，我是东邪狂想，本文是Redis、MySQL、Kafka系列第一篇。 本专题主要讲解Redis/MySQL/Kafka，先阐述它们之间的共性的设计思想，然后逐步讲解Redis…
-
【kafka消息里会有乱序消费的情况吗？如果有，是怎么解决的？】
文章目录 什么是消息乱序消费了？ 顺序生产，顺序存储，顺序消费 如何解决乱序 数据库乐观锁是怎么解决这个乱序问题吗 保证消息顺序消费两种方案 固定分区方案 乐观锁实现方案 前几天刷…
-
mac 安装kafka教程
kafka使用命令“brew install kafka ”安装，可参考：mac kafka安装教程(自动安装)_北漂人Java的博客-CSDN博客 1、下载kafka安装包 A…
-
分享8个分布式Kafka的使用场景
Kafka 最初是为海量日志处理而构建的。它保留消息直到过期，并让消费者按照自己的节奏提取消息。与它的前辈不同，Kafka 不仅仅是一个消息队列，它还是一个适用于各种情况的开源事件…
-
Kafka 面试题合集
🎈每日定期分享 | 面试求职经验 | 个人成长 开篇寄语 面试不必死记硬背，带着GPT去面试简直降维打击！ 为您推荐一款颠覆性的GPT面试助手软件：“会议面试精…
-
Kafka 如何保证消息不丢失？
今天分享的这道面试题，是一个工作 2 年的小伙伴私信给我的。 我觉得这个问题比较简单，本来不打算说，但是，唉~ 作为新的 UP 主满足粉丝的基本要求，才能获得更多的点赞呀~是吧。 …
-
Docker搭建Kafka教程（python使用kafka基础用法，生产消费）
图解 kafka 架构与工作原理 – 知乎 (zhihu.com)https://zhuanlan.zhihu.com/p/442468709 一、Docker 网络创…
-
kafka为什么不支持读写分离？
kafka为什么不支持读写分离？ 在kafka中，生产者写入消息，消费者读取消息的操作都是与 leader 副本进行交互的，从而实现的是一种主写主读的生产消费模型。kafka不支持…
-
【flink番外篇】15、Flink维表实战之6种实现方式-通过广播将维表数据传递到下游
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Kafka消息丢失：原因、解决方案和零丢失的配置
在使用Apache Kafka作为分布式消息系统时，消息丢失是一种常见的问题。消息丢失可能会导致数据不一致或功能故障，因此对于许多应用程序来说是不可接受的。本文将介绍Kafka消息…
