网站首页 kafkamanager 第5页
-
一种并行，背压的Kafka Consumer（kafka背压机制）
介绍几乎所有KafkaConsumer教程都是下面的代码：...
2024-07-11 wxchong 开源技术 8 ℃ 0 评论 -
Kafka存储层-日志管理（kafka数据存储）
Kafka的日志管理负责日志的创建、检索、清理，和日志相关的读写操作则交给日志实例去处理。每个TopicPartition都对应一个物理层面上的log实例，LogManager使用了logs管理了分区对应的日志实例。简化后的代...
2024-07-11 wxchong 开源技术 8 ℃ 0 评论 -
数仓/数开面试题真题总结(四)（数仓面试时应该讲些什么）
四.Kafka1.Kafka名词解释和工作方式...
2024-07-11 wxchong 开源技术 6 ℃ 0 评论 -
「Kafka」Leader丢失导致的Consumer挂起故障解决
现象最近发现线上的KafkaConsumerClient频繁出现无法消费的情况，导致offset积压。但是在重启KafkaBroker之后又正常了。而ClouderaManager在重启之前，我们发现三台broker中并没有Kak...
2024-07-11 wxchong 开源技术 7 ℃ 0 评论 -
浅谈Kafka2.8+在Windows下的搭建与使用
前言：周末空闲时间无意找到了一套个性化推荐的源码，整体项目运用了SSH，HDFS，Flume，Hive，Kafka，Spark，Scala等。运行时，本来通过spark计算业务埋点数据时，却发现本地没有Kafka。因为我一直也没使用过Kaf...
2024-07-11 wxchong 开源技术 7 ℃ 0 评论 -
走近kafka-文件存储（kafka高效文件存储设计特点）
在上一节中我们说到topic，它是用来存储一类消息的，每个topic内部实现又被分成多个partition，每个partition在存储层面是segment文件,每个segment分别由indexfile和datafile组成。在Kaf...
2024-07-11 wxchong 开源技术 7 ℃ 0 评论 -
为Kafka topic __consumer_offsets新增副本
__consumer_offsets__consumer_offsets是...
2024-07-11 wxchong 开源技术 10 ℃ 0 评论 -
Kafka 顺序消费线程模型的实践与优化
各类消息中间件对顺序消息实现的做法是将具有顺序性的一类消息发往相同的主题分区中，只需要将这类消息设置相同的Key即可，而Kafka会在任意时刻保证一个消费组同时只能有一个消费者监听消费，因此可在消费时按分区进行顺序消费，保证每个分区...
2024-07-11 wxchong 开源技术 9 ℃ 0 评论 -
如何搭建一个Kafka集群?（创建kafka）
这篇文章主要给大家介绍关于如何搭建一个Kafka的集群。通常情况下我们可以按照下面的步骤来执行，完成Kafka集群的搭建工作。如下所示。准备环境...
2024-07-11 wxchong 开源技术 10 ℃ 0 评论 -
干货分享:Kafka 源码阅读笔记（kafka源码是java还是scala）
作者：guolonglin，腾讯IEG后台开发工程师一、Kafka总览1）kafka集群是由broker组成，每个borker拥有一个controller，基于zookeeper做集群controllerleade...
2024-07-11 wxchong 开源技术 7 ℃ 0 评论
- 控制面板
- 网站分类
- 最新留言
-