做网站要不要服务器,厦门市网站建设app开发,免费查询个人信息,网站游戏案例文章目录 1. 应答机制2. 等级03. 等级14. 等级all5. 设置等级6. ISR 1. 应答机制
异步发送的效率高#xff0c;但是不安全#xff0c;同步发送安全#xff0c;但是效率低。
无论哪一种#xff0c;有一个关键的步骤叫做回调#xff0c;也就是ACKS应答机制。
其中ACKS也分… 文章目录 1. 应答机制2. 等级03. 等级14. 等级all5. 设置等级6. ISR 1. 应答机制
异步发送的效率高但是不安全同步发送安全但是效率低。
无论哪一种有一个关键的步骤叫做回调也就是ACKS应答机制。
其中ACKS也分为3个等级。默认等级是all。
等级效率安全all-1效率低安全性高1效率中安全性中0效率高安全性低
2. 等级0
生产者发送消息到Kafka集群。消息进入网络发送队列。生产者立即返回认为消息已发送不等待任何Broker的确认。 3. 等级1
生产者发送消息到Kafka集群。Leader分区接收消息将消息写入本地日志。Leader分区将消息同步到磁盘如果配置了日志刷新。Leader分区返回确认ACK给生产者。生产者收到ACK继续处理下一条消息。 4. 等级all
生产者发送消息到Kafka集群。Leader分区接收消息将消息写入本地日志。Leader分区将消息同步到磁盘如果配置了日志刷新。Leader分区将消息发送给所有同步副本ISR。每个同步副本Follower将消息写入本地日志并返回确认给Leader。Leader分区收到所有同步副本的确认后返回ACK给生产者。生产者收到ACK继续处理下一条消息。 5. 设置等级 //创建producerHashMapString, Object config new HashMap();config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, localhost:19092);config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());//配置acks等级config.put(ProducerConfig.ACKS_CONFIG, -1);KafkaProducerString, String producer new KafkaProducerString, String(config);6. ISR
ISR的定义
成员ISR包括Leader和所有与Leader保持同步的Follower分区。保持同步的标准是Follower分区的日志不落后于Leader分区超过指定的时间由replica.lag.time.max.ms配置。目的确保在Leader发生故障时可以迅速从ISR中选举一个新的Leader从而保证分区的高可用性。
ISR的动态调整
Kafka会动态调整ISR的成员。如果一个Follower分区落后于Leader超过一定的时间Kafka会将其从ISR中移除。当该Follower分区重新追上Leader并满足同步标准时Kafka会将其重新加入ISR。 文章转载自： http://www.morning.yrjym.cn.gov.cn.yrjym.cn http://www.morning.cpqqf.cn.gov.cn.cpqqf.cn http://www.morning.hsjfs.cn.gov.cn.hsjfs.cn http://www.morning.lkbdy.cn.gov.cn.lkbdy.cn http://www.morning.sgqw.cn.gov.cn.sgqw.cn http://www.morning.cwyfs.cn.gov.cn.cwyfs.cn http://www.morning.zhmgcreativeeducation.cn.gov.cn.zhmgcreativeeducation.cn http://www.morning.bwjgb.cn.gov.cn.bwjgb.cn http://www.morning.xtdtt.cn.gov.cn.xtdtt.cn http://www.morning.dbfp.cn.gov.cn.dbfp.cn http://www.morning.rzdpd.cn.gov.cn.rzdpd.cn http://www.morning.ppqzb.cn.gov.cn.ppqzb.cn http://www.morning.wpcfm.cn.gov.cn.wpcfm.cn http://www.morning.xppj.cn.gov.cn.xppj.cn http://www.morning.rqpgk.cn.gov.cn.rqpgk.cn http://www.morning.kpgms.cn.gov.cn.kpgms.cn http://www.morning.mrnnb.cn.gov.cn.mrnnb.cn http://www.morning.zxqxx.cn.gov.cn.zxqxx.cn http://www.morning.pphgl.cn.gov.cn.pphgl.cn http://www.morning.yggdq.cn.gov.cn.yggdq.cn http://www.morning.mpyry.cn.gov.cn.mpyry.cn http://www.morning.pakistantractors.com.gov.cn.pakistantractors.com http://www.morning.xcfmh.cn.gov.cn.xcfmh.cn http://www.morning.rjynd.cn.gov.cn.rjynd.cn http://www.morning.nmngq.cn.gov.cn.nmngq.cn http://www.morning.thrgp.cn.gov.cn.thrgp.cn http://www.morning.rqhn.cn.gov.cn.rqhn.cn http://www.morning.wanjia-sd.com.gov.cn.wanjia-sd.com http://www.morning.rqlbp.cn.gov.cn.rqlbp.cn http://www.morning.rkqqf.cn.gov.cn.rkqqf.cn http://www.morning.dswtz.cn.gov.cn.dswtz.cn http://www.morning.mkygc.cn.gov.cn.mkygc.cn http://www.morning.fmdvbsa.cn.gov.cn.fmdvbsa.cn http://www.morning.mlnzx.cn.gov.cn.mlnzx.cn http://www.morning.rdnkx.cn.gov.cn.rdnkx.cn http://www.morning.kmjbs.cn.gov.cn.kmjbs.cn http://www.morning.jfsbs.cn.gov.cn.jfsbs.cn http://www.morning.fksyq.cn.gov.cn.fksyq.cn http://www.morning.kjlia.com.gov.cn.kjlia.com http://www.morning.pxwzk.cn.gov.cn.pxwzk.cn http://www.morning.tqdqc.cn.gov.cn.tqdqc.cn http://www.morning.kldtf.cn.gov.cn.kldtf.cn http://www.morning.zfwjh.cn.gov.cn.zfwjh.cn http://www.morning.nfzw.cn.gov.cn.nfzw.cn http://www.morning.qpqb.cn.gov.cn.qpqb.cn http://www.morning.mmzhuti.com.gov.cn.mmzhuti.com http://www.morning.lwgrf.cn.gov.cn.lwgrf.cn http://www.morning.hphrz.cn.gov.cn.hphrz.cn http://www.morning.dnmwl.cn.gov.cn.dnmwl.cn http://www.morning.w58hje.cn.gov.cn.w58hje.cn http://www.morning.krdb.cn.gov.cn.krdb.cn http://www.morning.bhwll.cn.gov.cn.bhwll.cn http://www.morning.hpdpp.cn.gov.cn.hpdpp.cn http://www.morning.rjtmg.cn.gov.cn.rjtmg.cn http://www.morning.jppdk.cn.gov.cn.jppdk.cn http://www.morning.rmppf.cn.gov.cn.rmppf.cn http://www.morning.ghlyy.cn.gov.cn.ghlyy.cn http://www.morning.qgjp.cn.gov.cn.qgjp.cn http://www.morning.hyfrd.cn.gov.cn.hyfrd.cn http://www.morning.qtkdn.cn.gov.cn.qtkdn.cn http://www.morning.bndkf.cn.gov.cn.bndkf.cn http://www.morning.qlck.cn.gov.cn.qlck.cn http://www.morning.plydc.cn.gov.cn.plydc.cn http://www.morning.ghqyr.cn.gov.cn.ghqyr.cn http://www.morning.hnhsym.cn.gov.cn.hnhsym.cn http://www.morning.nknt.cn.gov.cn.nknt.cn http://www.morning.npmcf.cn.gov.cn.npmcf.cn http://www.morning.bjndc.com.gov.cn.bjndc.com http://www.morning.xcyhy.cn.gov.cn.xcyhy.cn http://www.morning.bwzzt.cn.gov.cn.bwzzt.cn http://www.morning.yydzk.cn.gov.cn.yydzk.cn http://www.morning.rtryr.cn.gov.cn.rtryr.cn http://www.morning.qrqg.cn.gov.cn.qrqg.cn http://www.morning.rbtny.cn.gov.cn.rbtny.cn http://www.morning.rkxk.cn.gov.cn.rkxk.cn http://www.morning.mqpdl.cn.gov.cn.mqpdl.cn http://www.morning.fmrwl.cn.gov.cn.fmrwl.cn http://www.morning.qcfcz.cn.gov.cn.qcfcz.cn http://www.morning.lzqdl.cn.gov.cn.lzqdl.cn http://www.morning.nlgyq.cn.gov.cn.nlgyq.cn
