首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
后端
01-01 08:00
后端
Kafka原理以及分区分配策略剖析
Kafka原理以及分区分配策略剖析,简介ApacheKafka是一个分布式的流处理平台(分布式的基于发布/订阅模式的消息队列(MessageQueue))。流处理平台有以下3个特性:可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。可以储存流式的记录,并且有较好的容错性。可以在流式记录产生时就进行处理。消息队列的两种模式点对点模式生产者将消息发送到Queue中,然后消费者从Qu
91
后端
01-01 08:00
后端
Kafka 3.0重磅发布,都更新了些啥?
Kafka 3.0重磅发布,都更新了些啥?,【编者的话】ApacheKafka是一个分布式开源流平台,被广泛应用于各大互联网公司。Kafka设计之初被用于消息队列,自2011年由LinkedIn开源以来,Kafka迅速从消息队列演变为成熟的事件流处理平台。Kafka具有四个核心API,借助这些API,Kafka可以用于以下两大类应用:建立实时流数据管道,可靠地进行数据传输,在系统或应用程序之间获取
88
后端
01-01 08:00
后端
Kafka
Kafka,消息队列有点对点方式和发布订阅方式消息队列作用有解耦、削峰、异步Kafka核心概念Broker:Kafka服务节点Topic:对消息进行分类Partition:对主题进行分区Replication:Leader和Flower,对分区备份Group:每个消费者组只能消费一条消息Docker安装Kafka安装zookeeperdockerpullwurstmeister/zookeeper
111
后端
01-01 08:00
后端
Kafka成长记4:Producer 元数据拉取源码原理(下)
Kafka成长记4:Producer 元数据拉取源码原理(下),上一节结尾,我们总结道:初始化KafkaProducer时并没有去拉取元数据,但是创建了Selector组件,启动了Sender线程,select阻塞等待请求响应。由于还没有发送任何请求,所以初始化时并没有去真正拉取元数据。真正拉取元数据是在第一次send方法调用时,会唤醒唤醒Selector之前阻塞的select(),进入第二次wh
83
后端
01-01 08:00
后端
Kafka成长3:Producer 元数据拉取源码原理(上)
Kafka成长3:Producer 元数据拉取源码原理(上),上一节我们分析了Producer的核心组件,我们得到了一张关键的组件图。你还记得么?简单概括下上面的图就是:创建了Metadata组件,内部通过Cluster维护元数据初始化了发送消息的内存缓冲器RecordAccumulator创建了NetworkClient,内部最重要的是创建了NIO的Selector组件启动了一个Sender线程
102
后端
01-01 08:00
后端
Kafka(七)深入原理--消费者consumer
一、消费方式 只要提到消息队列,必然会涉及到其推模式(push)和拉模式(pull),在kafka中,同样会涉及到。 consumer采用的时pull模式,从broker中去拉取消息。 为什么采用p...
164
后端
01-01 08:00
后端
Kafka Connect 实战 ---- 入门
前提 首先你需要了解MQ / Kafka相关的知识 本文目标 了解 Kafka Connect 基本概念与功能 什么是Kafka Connect Kafka Connect 是一款可扩展并且可靠地在...
247
后端
01-01 08:00
后端
Kafka Connect 实战 ---- 入门
前提 首先你需要了解MQ / Kafka相关的知识 本文目标 了解 Kafka Connect 基本概念与功能 什么是Kafka Connect Kafka Connect 是一款可扩展并且可靠地在...
65
后端
01-01 08:00
后端
Kafka原理概要
[TOC] 集群成员间的关系 我们知道,Kafka 是运行在 ZooKeeper 之上的,因为 ZooKeeper 是以集群形式出现的,所以 Kafka 也可以以集群形式出现。这也就涉及到多个生产者...
60
后端
01-01 08:00
后端
Kafka 系统学习
Apache Kafka 是什么? Kafka 是基于发布与订阅的消息系统。它最初由 LinkedIn 公司开发,之后成为 Apache 项目的一部分。Kafka 是一个分布式的,可分区的,冗余备份...
124
«
1
2
3
4
5
6
7
8
9
10
11
»