鍦ㄨKafka鐨勯珮鍙潬涔嬪墠锛屽厛鍦ㄨ瘎璁哄尯璇磋RNGNB鍚э紒浠€涔堟槸鍙潬鎬э紵澶у閮界煡閬撶郴缁熸灦鏋勬湁涓夐珮锛氣€滈珮鎬ц兘銆侀珮骞跺彂銆侀珮鍙敤鈥濓紝涓夎€呯殑閲嶈鎬т笉瑷€鑰屽柣銆傚浜庝换浣曚竴涓郴缁熸潵璇达紝鍚屾椂婊¤冻涓夐珮閮芥槸闈炲父鍥伴毦鐨勩€傚ぇ鍨嬩笟鍔＄郴缁熸垨浼犵粺鐨勪腑闂翠欢閮戒細鏋勫缓澶嶆潅鐨勬灦鏋勬潵纭繚瀹冦€傞櫎浜嗕互涓婁笁绉嶆ā寮忥紝杩樻湁涓€涓寚鏍囨柟鍚戜篃寰堥噸瑕侊紝閭ｅ氨鏄珮鍙潬锛屼綘鐢氳嚦鍙兘浼氭妸瀹冨拰鈥滈珮鍙敤鈥濇贩娣嗐€備簨瀹炰笂锛屼袱鑰呭苟涓嶇浉鍚屻€傞珮鍙敤浼氭洿鍊惧悜浜庢暣浣撴湇鍔＄殑鍙敤鎬э紝闃叉绯荤粺瀹曟満绛夈€傝€岄珮鍙潬鎬ф槸鎸囨暟鎹殑鍙潬鎬т繚璇併€備綘鍙互鐞嗚В涓衡€滈珮鍙潬鎬р€濇槸姣斾笁楂樼郴缁熸洿绮剧粏鐨勬蹇点€傞偅涔堜粈涔堟槸鏁版嵁鐨勯珮鍙潬鎬у憿锛熺患涓婃墍杩帮紝绯荤粺蹇呴』鎻愪緵鍙潬鐨勬暟鎹敮鎸侊紝涓嶈兘鍑虹幇涓㈠け銆侀噸澶嶇瓑閿欒銆傛墍浠ユ瘡涓€涓紑婧愪腑闂翠欢鍦ㄥ彂甯冪増鏈殑鏃跺€欓兘浼氶€氳繃鏂囨。鏉ュ０鏄庤嚜宸辨槸瓒呭彲闈犵殑锛屽氨鍍忔瘡涓殩鐢峰湪520閭ｅぉ璇寸殑涓€鏍枫€傛垜浠粖澶╃殑涓昏鍗″か鍗″氨鏄繖鏍蜂竴涓緥瀛愩€備竴浜涢噸瑕佺殑姒傚康鏄洜涓烘湁涓€娈垫椂闂存病鏈夎娑堟伅闃熷垪浜嗐€備负浜嗗府鍔╁ぇ瀹舵洿濂界殑鐞嗚В鏂囩珷锛屾垜浠厛鏉ュ洖椤句竴涓媖afka鐨勫熀鏈蹇碉細璁板綍锛氭秷鎭紝娑堟伅闃熷垪鐨勫熀鏈€氫俊鍗曞厓topic锛氫富棰橈紝鐩殑鏄娑堟伅杩涜鍒嗙被锛岄€氬父鍒嗗彂涓嶅悓涓氬姟绫诲瀷鐨勬秷鎭涓嶅悓topic鐨刾artition:鍒嗗尯锛屾瘡涓猼opic鍙互鍒涘缓澶氫釜partition锛屾瘡涓猵artition鐢变竴绯诲垪鏈夊簭涓斾笉鍙彉鐨勬秷鎭粍鎴愪互鏃ュ織锛圠og锛夊璞＄殑褰㈠紡浣撶幇銆傚壇鏈垎涓簂eader鍓湰鍜宖ollower鍓湰offset锛歰ffset锛屾瘡鏉℃秷鎭湪鏃ュ織鏂囦欢涓殑浣嶇疆瀵瑰簲涓€涓緷娆￠€掑鐨刼ffset锛屽彲浠ョ悊瑙ｄ负绫讳技鏁扮粍鐨勫瓨鍌ㄥ舰寮弍roducer锛歱roducer锛宲roduction鐨勯偅涓€杈筸essageconsumer锛氭秷璐硅€咃紝閫氬父涓嶅悓鐨勪笟鍔′細鏈変竴涓垨澶氫釜consumer缁勬垚涓€涓猚onsumer闆嗙兢broker锛歛gent锛屼竴涓狵afka闆嗙兢鐢变竴涓垨澶氫釜Kafka瀹炰緥缁勬垚锛屾瘡涓狵afka瀹炰緥绉颁负涓€涓唬鐞嗗涓婂浘鎵€绀猴紝涓€鍏辨湁topic1鍜宼opic2锛宼opic1鏈変袱涓猵artition锛宼opic2鍙湁涓€涓猵artition锛屾瘡涓猵artition鏈変竴涓猯eader鍓湰鍜屼袱涓猣ollower鍓湰锛屽垎甯冨湪鍚勪釜涓嶅悓鐨刟gent鑺傜偣涓娿€傚湪鍒嗗尯涓紝鍙湁leader鍓湰璐熻矗涓庣敓浜ц€呭拰娑堣垂鑰呯殑鏁版嵁浜や簰锛宖ollower鍓湰浼氬懆鏈熸€у湴浠巐eader鍓湰鎷夊彇鏁版嵁锛屼繚璇佹暣涓泦缇ょ殑鏁版嵁鍙敤鎬с€傚浣曚繚璇佹暟鎹殑楂樺彲闈犳€afka鏄€氳繃鍓湰鏈哄埗鏉ュ疄鐜版暟鎹瓨鍌ㄧ殑锛屾墍浠ラ渶瑕佷竴浜涙満鍒舵潵淇濊瘉璺ㄩ泦缇ょ殑鍓湰涔嬮棿鏁版嵁鑳藉鍙潬浼犺緭銆?銆佸壇鏈悓姝ラ噰闆嗙殑涓氬姟鏁版嵁灏佽鎴愭秷鎭湪绯荤粺涓祦閫氥€傜敱浜庢瘡涓粍浠跺垎甯冨湪涓嶅悓鐨勬湇鍔″櫒涓婏紝鍥犳涓婚涓庣敓浜ц€呭拰娑堣垂鑰呬箣闂寸殑鏁版嵁鍚屾鍙兘瀛樺湪涓€瀹氱殑鏃堕棿寤惰繜銆侹afka閫氳繃寤惰繜鑼冨洿鍒嗕负鍑犱釜涓嶅悓鐨勯泦鍚堬細AR锛圓ssignedReplicas锛夋槸鎸囧垎閰嶆暟鎹殑鍒嗗尯鍓湰锛岄€氬父鏄寚leader鍓湰+follower鍓湰銆侷SR锛圛nSyncReplicas锛夋槸鎸囦笌棰嗗鍓湰鏁版嵁淇濇寔鍚屾鐨勫壇鏈泦銆傚綋follower鍓湰鏁版嵁鍜宭eader鍓湰鏁版嵁淇濇寔鍚屾鏃讹紝杩欎簺鍓湰閮藉湪ISR涓紝ISR闆嗗悎浼氭牴鎹暟鎹殑鍚屾鐘舵€佸姩鎬佸彉鍖栥€侽SR锛圤utSyncReplicas锛変竴鏃ollower鍓湰鐨勬暟鎹悓姝ヨ繘搴﹁窡涓嶄笂leader锛屽氨浼氳鏀惧叆涓€涓彨OSR鐨勯泦鍚堜腑銆備篃灏辨槸璇达紝姝ら泦鍚堝寘鍚笉鍚屾鐨勫垎鍖哄壇鏈€侽K锛岄偅涔堝垽鏂槸鍚﹀悓姝ョ殑鏍囧噯鏄粈涔堝憿锛熶娇鐢ㄥ弬鏁皉eplica.lag.time.max.ms璁剧疆鏁版嵁鍚屾鏃堕棿宸紝榛樿鍊间负10s銆備竴鏃︿粠鍒嗗尯鍓湰鍜屼富鍒嗗尯鍓湰涔嬮棿鐨勬秷鎭樊寮傝秴杩?0s锛屽垯璁や负娑堟伅澶勪簬OSR澶辨鐘舵€併€傚鏋渇ollower鍦∣SR闆嗗悎涓紝閭ｄ箞鍦ㄩ€夋嫨鏂扮殑leader鏃讹紝瀹冧笉浼氳閫変负鏂扮殑leader銆?銆丄CK鍝嶅簲鏈哄埗鍒氭墠璇翠簡Kafka閫氳繃ack鍙戦€佹暟鎹悓姝ヤ俊鍙凤紝閭ｄ箞淇″彿鍙戦€侀鐜囨湁澶氬皯绉嶈缃憿锛焌ck=0鐢熶骇鑰呭彂閫佷竴娆℃秷鎭悗涓嶅啀鍙戦€併€備笉绠″彂閫佹垚鍔熶笌鍚︼紝濡傛灉鍙戦€佺殑娑堟伅鍦ㄩ€氫俊閫斾腑涓㈠け锛屾垨鑰呮病鏈夎繘琛岀鐩樻寔涔呭寲鎿嶄綔锛岄兘鍙兘瀵艰嚧娑堟伅涓㈠け銆傚畠鐨勪紭鐐规槸鎬ц兘闈炲父楂樸€傛兂鎯崇湅锛屼笉鐢ㄧ瓑瀵规柟鍥炲鍐嶅彂涓嬩竴鎵规秷鎭紝杩欐牱娑堟伅鐨勭瓑寰呮椂闂村氨鐪佷簡銆傚畠鍙互鍦ㄧ浉鍚岀殑鏃堕棿鑼冨洿鍐呭鐞嗘瘮鍏朵粬浜烘洿澶氱殑鏁版嵁銆傜己鐐规槸瀹冪殑鍙潬鎬х湡鐨勫緢浣庯紝鏁版嵁鐪熺殑鏄竴涓㈠氨涓€俛ck=1leader鏀跺埌娑堟伅骞跺啓鍏ユ湰鍦扮鐩樺悗璁や负娑堟伅澶勭悊鎴愬姛銆傝繖绉嶆柟娉曠殑鍙潬鎬т細姣斿墠涓€绉嶅ソ銆傚綋leader鏀跺埌娑堟伅骞跺啓鍏ユ湰鍦扮鐩樻椂锛屽氨璁や负娑堟伅澶勭悊鎴愬姛銆備笉绠ollower鏈夋病鏈夊悓姝ワ紝娑堟伅閮戒細杩斿洖缁檖roducer銆備絾鏄鏋滄鏃秔artitionleader鎵€鍦ㄧ殑broker瀹曟満锛岄偅涔堟暟鎹篃鏈夊彲鑳戒涪澶憋紝鎵€浠ollower鍓湰鐨勬暟鎹悓姝ラ潪甯搁噸瑕併€侹afka榛樿浣跨敤杩欑鏂瑰紡銆俛ck=-1鐢熶骇鑰呭彧鏈夋敹鍒板垎鍖哄唴鎵€鏈夊壇鏈殑鍝嶅簲ACK鎵嶄細璁や负娑堟伅鎺ㄩ€佹垚鍔熴€傝繖绉嶆柟寮忚櫧鐒跺湪淇濊瘉鏁版嵁鍙潬鏂归潰鍋氬緱寰堝ソ锛屼絾鏄€ц兘杈冨樊锛屽奖鍝嶅悶鍚愰噺锛屾墍浠ヤ竴鑸笉閲囩敤銆傞偅涔堝畠鏄竾鏃犱竴澶辩殑鍚楋紵鎴栬銆傛渶閲嶈鐨勮繕鏄鐪嬪壇鏈暟鎹槸鍚﹀悓姝ャ€傚鏋渓eader鍓湰鍦╬roducer鏀跺埌response娑堟伅涔嬪墠灏辨寕浜嗭紝producer浼氬洜涓烘病鏈夋敹鍒版秷鎭€岄噸澶嶅彂閫佹秷鎭紝鍙兘浼氶€犳垚鏁版嵁閲嶅銆傚浣曡В鍐筹紵鍙渶纭繚涓氬姟鏄箓绛夌殑銆傛垜浠彲浠ラ€氳繃request.required.acks鍙傛暟鏉ユ帶鍒舵秷鎭殑鍙戦€侀鐜囥€傝寰楁枃绔犱笉閿欏彲浠ュ井淇℃悳绱⑩€滃偛鍐扳€濈涓€鏃堕棿闃呰锛屽叧娉ㄥ悗鍥炲銆愯祫璁€戣繖閲屾湁鎴戝噯澶囩殑涓€绾垮ぇ鍘傞潰璇曡祫鏂欏拰绠€鍘嗘ā鏉裤€?.娑堟伅璇箟娑堟伅绨囦綔涓轰竴涓暣浣撴槸涓€涓鏉傜殑绯荤粺銆傛墍浠ュ湪杩欎釜杩囩▼涓彲鑳戒細鍥犱负鍚勭鍘熷洜瀵艰嚧娑堟伅浼犻€掗敊璇€侹afka涓鸿繖浜涘彲鑳界殑鍦烘櫙瀹氫箟浜嗙浉搴旂殑娑堟伅璇箟銆俛tmostonce琛ㄧず娑堟伅鍙兘琚秷璐硅€呮秷璐?娆℃垨1娆°€傚鏋滃満鏅槸杩欐牱鐨勶細娑堟伅浠庡垎鍖哄垎鍙戝埌娑堣垂鑰呴泦缇わ紝娑堣垂鑰呭皢鑷繁鏀跺埌鐨勬秷鎭憡璇夐泦缇ゃ€傞泦缇ゆ敹鍒版秷鎭悗锛屽亸绉婚噺浼氬悜鍚庣Щ鍔紝娑堣垂鑰呬細瀛樺偍鏁版嵁杩涜鎸佷箙鍖栥€備綘涓€瀹氬凡缁忔兂鍒颁簡銆傜涓夋锛屽鏋滄秷璐硅€匒鍦ㄦ秷璐硅€呭叆搴撶殑鏃跺€欏洜涓烘煇绉嶅師鍥犳寕鎺変簡锛岄偅涔堣繖涓秷璐硅€呭垏鎹㈠埌闆嗙兢鐨勬秷璐硅€匓涔嬪悗锛屾暟鎹繕娌℃湁鍏ュ簱銆傝繖鏃跺€欏垎鍖烘槸瀹屽叏鏈煡鐨勶紝鎵€浠ヨ繖浼氶€犳垚涓€涓棶棰橈細鏁版嵁涓㈠け銆傝嚦灏戜竴娆¤〃绀哄垎鍖哄垎鍙戠殑娑堟伅鑷冲皯琚秷璐逛竴娆°€傞€氫俊杩囩▼濡備笅锛氭秷鎭粠鍒嗗尯鍒嗗彂鍒版秷璐硅€呫€傞泦缇ゆ秷璐硅€呭皢鏁版嵁鏀惧叆鏁版嵁搴撹繘琛屾寔涔呭寲銆傛秷璐硅€呭憡璇夐泦缇や粬鏀跺埌鐨勬秷鎭€傞泦缇ゆ敹鍒板悗锛屽亸绉婚噺浼氬悜鍚庣Щ鍔ㄣ€傚亣璁炬秷璐硅€呯粍鍦ㄥ皢鏁版嵁瀛樺叆鏁版嵁搴撲箣鍚庯紝娑堣垂鑰匒鍦ㄥ悜鍒嗗尯杩斿洖鏁版嵁鐨勮繃绋嬩腑鎸備簡锛屽垎鍖轰細鍥犱负鏀朵笉鍒板搷搴擜CK鑰岄噸鏂板彂閫佹暟鎹€傛鏃舵秷璐硅€匓鍙兘浼氬啀娆″瓨鍌ㄥ師鏉ョ殑娑堟伅锛屼粠鑰屽鑷存暟鎹噸澶嶃€傚湪娌℃湁浠讳綍骞傜瓑鎬т繚鎶ょ殑鎯呭喌涓嬶紝姣斿閲嶅杞处銆佽繕娆俱€佸彔鍔犵Н鍒嗭紝缁撴灉鍙兘鏄嚧鍛界殑銆俥xactlyonce琛ㄧず娑堟伅鍙互鎭板ソ琚秷璐逛竴娆¤€屼笉浼氫涪澶辨垨閲嶅銆傛牴鎹嚦灏戜竴娆＄殑鎯呭喌锛屽亣璁綾onsumerA鍦ㄥ悜partition杩斿洖ack鐨勮繃绋嬩腑宕╂簝浜嗐€傞偅涔坈onsumerB灏变笉浼氭寜鐓artition鐨刼ffset浜嗭紝瀹冧細鍏堝幓鏁版嵁搴撴煡鐪嬫渶鏂版秷鎭搴旂殑offset锛岀劧鍚庢牴鎹繖涓猳ffset杩斿洖鍒発afka闆嗙兢浠庡搴旂殑offset寮€濮嬶紝杩欐牱鍙互閬垮厤娑堟伅閲嶅鍜屾秷鎭涪澶便€備笉鐭ラ亾鏈夊灏戞湅鍙嬬湅杩囪繖绡囥€傚鏋滅洰鍓嶄负姝㈣寰楁枃绗旇繕涓嶉敊锛屽彲浠ュ府鎴戠偣涓禐锛岃鎴戠湅鐪嬫湁澶氬皯濂藉鐨勫疂瀹濄€?銆佹暟鎹埅鏂満鍒舵垜浠竴寮€濮嬪氨璇磋繃锛岀湡姝ｅ鐞嗘暟鎹殑鏄痩eader鍓湰锛宖ollower鍓湰鍙礋璐ｆ暟鎹殑鍚屾鍜屽瓨鍌ㄣ€傚鏋滃洜涓簂eader鎸備簡瀵艰嚧涓よ€呮暟鎹笉涓€鑷存€庝箞鍔烇紵鍦ㄨ涓€鑷存€т繚璇佽繃绋嬩箣鍓嶏紝闇€瑕佷簡瑙ｄ竴涓婯afka鐢ㄦ潵琛ㄧず鍓湰鏁版嵁鍚屾鐨勪袱涓蹇碉細HW锛圚ighWatermark锛夛細涓枃缈昏瘧涓洪珮姘翠綅绾匡紝鐢ㄤ簬鍙嶆槧鍓湰闂存暟鎹悓姝ョ殑鐩稿浣嶇疆銆傛秷璐硅€呮渶澶氬彧鑳芥秷璐瑰埌HW鎵€鍦ㄧ殑浣嶇疆锛岄€氳繃HW鎴戜滑鍙互鍒ゆ柇鏁版嵁鏄惁瀵瑰壇鏈彲瑙併€侺EO(LogEndOffset)锛氫笅涓€鏉¤鍐欏叆鐨勬秷鎭殑璁板綍浣嶇疆銆俵eader鍓湰浠巔roducer鑾峰彇娑堟伅锛宖ollower鍓湰浠巐eder瀹炴椂鍚屾鏁版嵁銆傛鏃朵粬浠殑鍚屾鏁版嵁鏄竴鑷寸殑锛屽悓姝ュ埌2鐨勪綅缃紝涓嬩竴鏉″啓鍏ョ殑娑堟伅鏄痮ffset4锛氬亣璁炬剰澶栫殑leader瀹曟満锛宖ollower琚€変负鏂扮殑leader锛岀劧鍚庢渶鏂扮殑offset4鑰?涓槸producer鍐欑殑锛氫竴娈垫椂闂村悗锛屽師leader閫氳繃淇鎭㈠鏈嶅姟锛屼細鍙戠幇鑷繁鍜屾柊leader涔嬮棿鐨勬暟鎹笉涓€鑷寸殑锛氫负浜嗕繚璇佹暟鎹殑涓€鑷存€э紝涓€鏂瑰繀椤昏杩Ε鍗忋€傚洜涓烘暟鎹湪涓嶆柇鍒锋柊锛屾鏃惰€乴eader鐨勪紭鍏堢骇浼氫綆浜庢柊leader锛屾墍浠ヤ細鎶婅嚜宸辩殑鏁版嵁鎴柇鍒板拰鏂發eader鐩稿悓鐨凥W鍜孡EO浣嶇疆锛屼繚璇佹暟鎹柊棰嗗鑰呯殑韬唤蹇呴』鐩稿悓銆傚氨鏄疜afka鐨勬暟鎹埅鏂満鍒躲€?銆佹暟鎹竻娲楁満鍒朵笌鍏朵粬涓棿浠剁浉鍚屻€侹afka鐨勪富瑕佸姛鑳芥槸閫氫俊锛屾墍浠ュ嵆浣挎暟鎹繚瀛樺湪纾佺洏涓婏紝浠嶇劧浼氬崰鐢ㄤ竴瀹氱殑绌洪棿銆備负浜嗚妭鐪佸瓨鍌ㄧ┖闂达紝瀹冧細閫氳繃涓€浜涙満鍒舵竻鐞嗚繃鏈熸暟鎹€傛棩蹇楀垹闄ゆ棩蹇楀垹闄や細鐩存帴鍒犻櫎鏃ュ織娈碉紝Kafka浼氱淮鎶や竴涓畾鏃朵换鍔″畾鏈熸鏌ュ拰鍒犻櫎鈥滆繃鏈熸暟鎹€濄€傚熀浜庢椂闂寸殑鏃ュ織鍒犻櫎鍦ㄦ瘡涓棩蹇楁鏂囦欢涓淮鎶や竴涓渶澶ф椂闂存埑锛屼互纭褰撳墠閰嶇疆鐨勫垹闄ゆ椂闂达紝姣忓綋鏈夋柊娑堟伅鍐欏叆鏃ュ織娈垫椂锛岃瀛楁灏变細鏇存柊銆備竴涓棩蹇楁鍐欐弧鍚庯紝灏嗕笉鍐嶆帴鏀舵柊鐨勬秷鎭紝瀹冧細鍒涘缓涓€涓柊鐨勬棩蹇楁鏂囦欢鍚戝叾涓啓鍏ユ暟鎹€傛瘡涓棩蹇楁鏂囦欢琚～婊″悗锛屽叾鏈€澶ф椂闂存埑淇濇寔涓嶅彉銆侹afka鍙互閫氳繃姣旇緝褰撳墠鏃堕棿鍜屾渶澶ф椂闂存埑鏉ュ垽鏂棩蹇楁鏂囦欢鏄惁杩囨湡銆侹afka榛樿閰嶇疆log.retention.hours=168锛屼篃灏辨槸7澶╃殑鏃ュ織淇濈暀鏃堕棿銆傚熀浜庡閲忓ぇ灏忕殑鏃ュ織鍒犻櫎鍜屼笂闈㈢殑鏂规硶鏄竴鏍风殑锛屽彧鏄繖娆℃崲浜嗘椂闂村埌绌洪棿銆侹afka浼氭牴鎹瘡涓棩蹇楁绌洪棿鐨勫ぇ灏忚绠椾竴涓€诲閲忛槇鍊硷紝鐒跺悗璁＄畻褰撳墠瀹為檯绌洪棿澶у皬涓庢€诲閲忛槇鍊肩殑宸€笺€傚鏋滃樊寮傚ぇ浜庡崟涓棩蹇楁鏂囦欢鐨勫ぇ灏忥紝鍒欐渶鏃х殑鏂囦欢灏嗚鍒犻櫎銆傛棩蹇楁鏂囦欢锛屽惁鍒欎笉鍋氫换浣曞鐞嗐€傚悓鏍凤紝杩欎釜闃堝€间篃鍙互閫氳繃log.retention.bytes鍙傛暟鏉ヨ缃€傛棩蹇楀帇缂㎏afka鐨勬秷鎭槸鐢遍敭鍊肩粍鎴愮殑銆傚鏋滄棩蹇楁涓瓨鍦ㄥ鏉ey鐩稿悓浣唙alue涓嶅悓鐨勬暟鎹紝瀹冧細閫夋嫨鎬х殑娓呴櫎鏃х殑鏁版嵁锛屼繚鐣欐渶鏂扮殑璁板綍銆傚叿浣撶殑鍘嬬缉鏂瑰紡鏄垱寤轰竴涓猚heckpoint鏂囦欢锛屼粠鏃ュ織鐨勮捣濮嬩綅缃亶鍘嗗埌鏈€澶х粨鏉熶綅缃紝鐒跺悗灏嗘瘡鏉℃秷鎭殑key鍜宬ey瀵瑰簲鐨刼ffset淇濆瓨鍦ㄤ竴涓浐瀹氬閲忕殑SkimpyOffsetMap涓€傝繖鏍凤紝鍓嶉潰鐨勫€煎氨浼氳鍚庨潰鐨勫€艰鐩栨帀銆傚鏋滄棩蹇楁枃浠朵腑瀛樺湪鐩稿悓鐨勯敭锛屽垯鍙繚鐣欐渶鏂扮殑涓€涓€傛€荤粨Kafka閫氳繃ACK鍝嶅簲鏈哄埗淇濊瘉涓嶅悓缁勪欢涔嬮棿鐨勯€氫俊鏁堢巼锛岄€氳繃鍓湰鍚屾鏈哄埗銆佹暟鎹埅鏂拰鏁版嵁娓呮礂鏈哄埗瀹炵幇鏁版嵁绠＄悊绛栫暐锛屼繚璇佹暣涓郴缁熺殑杩愯鏁堢巼銆備綔涓哄悓鏃跺叿鏈夐珮鎬ц兘鍜岄珮鍙潬鎬х殑娑堟伅涓棿浠讹紝Kafka鍙互澶歌€€鐨勫湴鏂瑰お澶氫簡銆傚鏋滄湰鏂囧鎮ㄦ湁甯姪锛岃鐐瑰嚮鍙充笅瑙掔殑灏忔媷鎸囷紝涓嬫鎴戜滑浼氳缁嗚瑙afka鏄浣曞疄鐜板壇鏈棿鏁版嵁浼犺緭鐨勩€備綘鐭ラ亾鐨勮秺澶氾紝浣犱笉鐭ラ亾鐨勫氨瓒婂銆傚ぇ瀹剁殑鐐硅禐鍜岃瘎璁哄鎴戞潵璇村緢閲嶈銆傚鏋滆繖绡囨枃绔犲府鍔╀綘瀵筀afka鏈変簡鏇村鐨勪簡瑙ｏ紝鍙互鍦ㄨ瘎璁哄尯鍙戜竴娉⑩€滃彉寮衡€濄€備篃甯屾湜浣犵殑bug鍜屼笅鍥句竴鏍凤紝馃ず鍥烉煠哄洖馃ず鍥烇紒涓嬫瑙併€傛枃绔犳寔缁洿鏂帮紝寰俊鎼滅储鈥滃偛鍐扳€濆嵆鍙涓€鏃堕棿闃呰锛屽叧娉ㄥ悗鍥炲銆愯祫璁€戣繖閲屾湁鎴戜负涓€绾垮ぇ鍘傚噯澶囩殑闈㈣瘯璧勬枡鍜岀畝鍘嗘ā鏉裤€傛湰鏂囧凡鏀跺綍鍒癎itHubhttps://github.com/JavaFamily锛岄噷闈㈡湁澶у巶闈㈣瘯瀹屾暣娴嬭瘯绔欙紝娆㈣繋Star銆?/p>
