首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
后端
01-01 08:00
后端
Kafka源码分析16-消息有异常如何处理?
Kafka源码分析16-消息有异常如何处理?,privatevoidcompleteBatch(RecordBatchbatch,ProduceResponse.PartitionResponseresponse,longcorrelationId,longnow){//如果处理成功那就是成功了,但是如果服务端那儿处理失败了,是不是也要给我们发送回来异常的信息。//error这个里面存储的就是服务
94
后端
01-01 08:00
后端
Kafka源码分析17-如何处理超时的批次
Kafka源码分析17-如何处理超时的批次,上文Kafka源码分析16-消息有异常如何处理?分析了消息异常了Producer如何处理,本文将分析Producer如何处理超时的批次?继续看Sender的poll()方法:voidrun(longnow){/***步骤六:*对超时的批次是如何处理的?*/ListexpiredBatches=this.accumulator.abortExpiredBa
129
后端
01-01 08:00
后端
Kafka源码分析15-消息发送完了内存怎么处理?
Kafka源码分析15-消息发送完了内存怎么处理?,Kafka源码分析14-如何处理响应消息Producer已经成功把消息发送出去了,本文分析生产者成功发送消息之后内存怎么处理?直接看Sender线程的completeBatch()方法:privatevoidcompleteBatch(RecordBatchbatch,ProduceResponse.PartitionResponserespon
96
后端
01-01 08:00
后端
Kafka源码分析14-如何处理响应消息
Kafka源码分析14-如何处理响应消息,本文分析Producer如何响应消息,NetworkClient的poll():publicListpoll(longtimeout,longnow){/***在这个方法里面有涉及到kafka的网络的方法,但是*目前我们还没有给大家讲kafka的网络,所以我们分析的时候*暂时不用分析得特别的详细,我们大概知道是如何获取到元数据*即可。等我们分析完了kafk
87
后端
01-01 08:00
后端
Kafka源码分析10-Producer终于和broker建立连接了
Kafka源码分析10-Producer终于和broker建立连接了,从Kafka源码分析9-若网络没建立好会发送消息吗中得知,如果网络没有建立完成,是不会发送消息的。本文就讲解producer与broker是如何建立连接的,直接看sender线程的步骤八:{//省略。。/***步骤八:*真正执行网络操作的都是这个NetWorkClient这个组件*包括:发送请求,接受响应(处理响应)*///我们
87
后端
01-01 08:00
后端
Kafka源码分析11-Producer终于发送请求了
Kafka源码分析11-Producer终于发送请求了,上篇文章Kafka源码分析10-Producer终于和broker建立连接了Producer和broker建立网络连接了,本文分析Producer发送网络请求。看看Sender线程run方法,主要分析步骤五、七、八。{/***步骤五:**我们有可能要发送的partition有很多个,*很有可能有一些partition的leaderpartit
83
后端
01-01 08:00
后端
Kafka源码分析18-如何处理长时间没有接收到响应的消息
Kafka源码分析18-如何处理长时间没有接收到响应的消息,我们直接看NetworkClient的poll()方法:publicListpoll(longtimeout,longnow){//步骤三:处理响应,响应里面就会有我们需要的元数据。handleAbortedSends(responses);handleCompletedSends(responses,updatedNow);/***这个
68
后端
01-01 08:00
后端
Kafka源码分析19-Producer常用配置参数
Kafka源码分析19-Producer常用配置参数,这里是关于KafkaProducer一些配置的说明,内容来自官方文档ProducerConfigs以及自己的一些个人理解,这里以官方文档保持一致,按其重要性分为三个级别进行讲述(涉及到权限方面的参数,这里先不介绍)。highimportancemediumimportance下面的这些参数虽然被描述为medium,但实际上对Producer的吞
103
后端
01-01 08:00
后端
Kafka源码分析20-Producer源码总结
Kafka源码分析20-Producer源码总结,1.kafka中producer源码目录《01Kafka源码深度剖析-前言》《02Kafka源码深度剖析-源码阅读环境搭建》《03Kafka源码深度剖析-源码分析思路》《04Kafka源码深度剖析-从一个demo开始》《05Kafka源码深度剖析-Producer核心流程介绍》《06Kafka源码深度剖析-Producer初始化》《07生产者源码之
91
后端
01-01 08:00
后端
Kafka-无认证+SASL/SCRAM
Kafka-无认证+SASL/SCRAM,说明:最早生产环境采用kafka单节点并且没有认证方式,现在考虑到安全问题,需要增加认证。因涉及到的业务系统过多,不容易协调统一变更,所以无认证方式+认证方式并存(SCRAM可以动态增加用户)测试环境验证大体步骤无认证方式启动zk+kafka创建主题并生产增加安全端口认证9092无认证9093端口认证使用无认证9092端口消费/使用认证9093端口消费实施
120
«
1
2
3
4
5
6
7
8
9
10
11
»