澶у濂斤紝鎴戞槸Java鍚庣绋嬪簭灏氶濡嶐煂枫€傚鏋滃枩娆㈡垜鐨勬枃绔狅紝璇风偣璧炩灂鍏虫敞鉂わ笍锛岃鎴戜滑鎴愪负鏇村ソ鐨勬垜浠瑍1.Topic璇濋鍙互鐞嗚В涓轰竴涓被鍒殑鍚嶇О銆侹afka涓殑娑堟伅浠ヤ富棰樹负鍗曚綅杩涜鍒嗙被锛岀敓浜ц€呰礋璐ｅ悜鐗瑰畾涓婚鍙戦€佹秷鎭紝娑堣垂鑰呰礋璐ｈ闃呬富棰樺苟娑堣垂銆傚彂閫佸埌Kafka闆嗙兢鐨勬瘡鏉℃秷鎭兘蹇呴』鎸囧畾涓€涓富棰樸€?.PartitionPartition锛堝垎鍖猴級鏄疜afka鐨勪竴涓牳蹇冩蹇点€侹afka灏嗕竴涓富棰樺垝鍒嗕负涓€涓垨澶氫釜鍒嗗尯銆傛瘡涓垎鍖哄湪鐗╃悊涓婂搴斾竴涓洰褰曘€傚垎鍖虹洰褰曞瓨鏀惧垎鍖虹殑鏃ュ織娈碉紙segment锛夛紝鍖呮嫭鏃ュ織鐨勬暟鎹枃浠跺拰涓や釜绱㈠紩鏂囦欢銆傜劧鍚庢瘡涓垎鍖哄搴斾竴涓垨澶氫釜鍓湰锛岀敱涓€涓狪SR鍒楄〃缁存姢銆傛敞鎰忥細鍒嗗尯鏁板彲浠ュぇ浜庤妭鐐规暟锛屼絾鍓湰鏁颁笉鑳藉ぇ浜庤妭鐐规暟锛屽洜涓哄壇鏈渶瑕佸垎鍒颁笉鍚岀殑鑺傜偣鎵嶈兘杈惧埌澶囦唤鐨勭洰鐨勩€備竴涓富棰樹腑鐨勬秷鎭噺闈炲父澶э紝鍙互閫氳繃鍒嗗尯璁剧疆灏嗚繖浜涙秷鎭垎甯冨紡瀛樺偍銆備緥濡傦紝涓€涓富棰樺垱寤?涓垎鍖恒€傜劧鍚庝富棰樹腑鐨勬秷鎭皢鍒嗗埆瀛樺偍鍦ㄨ繖涓変釜鍒嗗尯涓€備负涓€涓富棰樺垱寤哄涓垎鍖猴細./kafka-topics.sh--create--zookeeperlocalhost:2181--partitions2--topictest1鏌ョ湅涓婚鍒嗗尯淇℃伅锛?/kafka-topics.sh--describe--zookeeperlocalhost:2181--topictest1鍒嗗尯鐨勪綔鐢細鍙互鍒嗗竷寮忓瓨鍌紱鍙互骞惰鍐欙紱瀹冨疄闄呬笂瀛樺湪浜巇ata/kafka-logs/test-0鍜宼est-1涓殑0000000.log鏂囦欢涓€傚畾鏈熷皢娑堣垂鍒嗗尯鐨刼ffset鎻愪氦缁橩afka鐨勫唴閮╰opic锛歘_consumer_offsets銆傛彁浜よ繃鍘荤殑鏃跺€欙紝key鏄痗onsumerGroupId+topic+partitionnumber锛寁alue鏄綋鍓峯ffset鐨勫€笺€侹afka浼氬畾鏈熸竻鐞唗opic涓殑娑堟伅锛屾渶鍚庝繚鐣欐渶鏂扮殑涓€鏉℃暟鎹€傚洜涓篲_consumer_offsets鍙兘浼氭敹鍒伴珮骞跺彂鐨勮姹傦紝鎵€浠afka榛樿缁欏畠鍒嗛厤浜?0涓猵artition锛堝彲浠ラ€氳繃offsets.topic.num.partitions璁剧疆锛夛紝杩欐牱鍙互閫氳繃鍔犳満鍣ㄦ潵鎶垫姉澶у苟鍙戙€傚彲浠ヤ娇鐢ㄤ互涓嬪叕寮忔潵閫夋嫨娑堣垂鑰呮秷璐圭殑鍋忕Щ閲忓簲鎻愪氦鍒癬_consumer_offsets鐨勫摢涓垎鍖猴細hash(consumerGroupId)%__consumer_offsets涓婚鐨勫垎鍖烘暟銆傛湰鏂囧弬涓庢€濈淮绉戞妧璁烘枃寰侀泦锛屾鍦ㄩ槄璇荤殑鏈嬪弸娆㈣繋鍔犲叆銆?/p>
