关于 # Kafka 的文章

这是关于 # Kafka 标签的相关文章列表

联合漏洞预警服务(2022-07-19 暂停开放)

置顶联合漏洞预警服务(2022-07-19 暂停开放)

关于在线社工库关闭的问题 TOOBUG博客自2016年开始与之前守夜人平台进行合作,充分利用守夜人平台的预警中心,为双方会员提供信息安全预警、账号行为分析、个人信息检索、人际关系分析、用户网络指纹记录、精准IP定位等...

【Kafka】消息可靠性保证

热文【Kafka】消息可靠性保证

其实，没有一个中间件能够做到百分之百的完全可靠，可靠性更多的还是基于几个9的衡量指标，比如4个9、5 个9。软件系统的可靠性只能够无限去接近100%，但不可能达到100%。所以kafka如何是实现最大可能的可靠性呢？...

【Kafka】原理分析：Consumer消费规则

热文【Kafka】原理分析：Consumer消费规则

在实际生产过程中，每个topic都会有多个partitions，多个partitions的好处在于，一方面能够对 broker上的数据进行分片有效减少了消息的容量从而提升io性能。另外一方面，为了提高消费端的消费能...

【Kafka】原理分析：分区副本机制

热文【Kafka】原理分析：分区副本机制

1.副本机制 Kafka的每个topic都可以分为多个Partition，并且多个partition会均匀分布在集群的各个节点下。虽然这种方式能够有效的对数据进行分片，但是对于每个partition来说，都是单点的，...

【Kafka】原理分析：详解副本协同流程

热文【Kafka】原理分析：详解副本协同流程

上一篇【Kafka】原理分析：分区副本机制我们介绍了什么是分区副本机制，里面提到了副本的协同，那么副本间数据同步的具体过程是什么样呢？本篇我们就一起来看看… 1.Leader副本接收消息 1.1 处理流程 Produ...

【Kafka】原理分析：Producer分发规则

热文【Kafka】原理分析：Producer分发规则

消息是kafka中最基本的数据单元，在kafka中一条消息由以下三部分构成： topic：消息属于哪个消息集合 value：消息具体内容 key：与分区算法一起决定当前消息发送到那个partition 消息在 kaf...

【Kafka】原理分析：磁盘存储性能问题优化

热文【Kafka】原理分析：磁盘存储性能问题优化

1.顺序写现在大部分企业仍然用的是机械结构的磁盘，如果把消息以随机的方式写入到磁盘，那么磁盘首先要做的就是寻址，也就是定位到数据所在的物理地址，在磁盘上就要找到对应的柱面、磁头以及对应的扇区；这个过程相对内存来说会...

【Kafka】原理分析：消息的文件存储机制

热文【Kafka】原理分析：消息的文件存储机制

消息发送端发送消息到broker上以后，消息是如何持久化的呢？那么这篇我们就来看看kafka是如何存储消息的。首先需要了解的是，kafka是使用日志文件的方式来保存生产者和发送者的消息，每条消息都有一个oﬀset值...

【Kafka】原理分析：关于Topic和Partition(分区)

热文【Kafka】原理分析：关于Topic和Partition(分区)

1.Topic 在kafka中，topic是一个存储消息的逻辑概念，可认为是一个消息集合。每条消息发送到kafka集群的消息都有一个类别。每个topic可以有多个生产者向它发送消息，也可以有多个消费者去消费其中的消...

【Kafka】基本使用：SpringBoot整合Kafka-clinets

热文【Kafka】基本使用：SpringBoot整合Kafka-clinets

首先说明一点，SpringBoot 的版本和 Kafka-clinets 的版本有一个对照表格，如果没有按照正确的版本来引入，那么会存在版本问题导致ClassNotFound的问题，具体请参考 https://spr...

【Kafka】基本使用：关于Consumer的几个概念

热文【Kafka】基本使用：关于Consumer的几个概念

上一篇，我们在【Kafka】基本使用：Java操作Kafka（kafka-clients）看到了使用kafka-clients去操作Kafka，但是在Consumer的那几个配置含义还不清楚，这篇我们就一起来看一下…...