澶у濂斤紝鎴戞槸Java鍚庣绋嬪簭灏氶濡嶐煂枫€傚鏋滃枩娆㈡垜鐨勬枃绔狅紝娆㈣繋鐐硅禐鉃曞叧娉ㄢ潳锔忥紝璁╂垜浠竴璧锋垚涓烘洿濂界殑鎴戜滑~Kafka闆嗙兢鍜屽壇鏈蹇?.鎼缓涓€涓猭afka闆嗙兢锛屼负3涓猙roker鏂板缓3涓猻erver.properties鏂囦欢锛歴erver.propertiesbroker銆俰d=0
listeners=PLAINTEXT://192.168.65.60:9092
log.dir=/usr/local/data/kafka-logsserver1.propertiesbroker.id=1
listeners=PLAINTEXT://192.168.65.60:9093
log.dir=/usr/local/data/kafka-logs-1server2.propertiesbroker.id=2
listeners=PLAINTEXT://192.168.65.60:9094
/>log.dir=/usr/local/data/kafka-logs-2鍚姩3鍙版湇鍔″櫒锛?/kafka-server-start.sh-daemon../config/server0.properties
./kafka-server-start.sh-daemon../config/server1.properties
./kafka-server-start.sh-daemon../config/server2.properties鏋勫缓鍚庯紝妫€鏌k涓殑/brokers/ids锛屾煡鐪嬫槸鍚﹀惎鍔ㄦ垚鍔熴€?.鍓湰鐨勬蹇靛壇鏈槸鍒嗗尯鐨勫浠姐€傚湪涓€涓泦缇や腑锛屼笉鍚岀殑鍓湰閮ㄧ讲鍦ㄤ笉鍚岀殑broker涓娿€傚垱寤?涓富棰橈紝2涓垎鍖猴紝3涓壇鏈€傚懡浠ゅ涓嬶細./kafka-topics.sh--create--zookeeper172.16.253.35:2181--replication-factor3--partitions2--topicmy-replicated-topic閫氳繃鏌ョ湅topic淇℃伅锛屽叧閿叾涓殑鏁版嵁锛歳eplicas锛氬綋鍓嶅壇鏈腑瀛樺湪鐨刡roker鑺傜偣锛沴eader锛氬壇鏈腑鐨勬蹇碉紱姣忎釜鍒嗗尯閮芥湁涓€涓唬鐞嗕綔涓洪瀵艰€呫€傛秷鎭彂閫佽€呮牴鎹壇鏈殑棰嗗鑰呭湪鍝釜浠ｇ悊涓婃潵鍐冲畾灏嗘秷鎭彂閫佸埌鍝釜浠ｇ悊銆傚壇鏈腑鐨勯瀵艰€呬笓鐢ㄤ簬鎺ユ敹娑堟伅銆傚叾浠杅ollower鏀跺埌娑堟伅鍚庯紝閫氳繃poll鍚屾鏁版嵁銆侳ollower锛歭eader澶勭悊鏈垎鍖虹殑鎵€鏈夎鍐欒姹傦紝follower琚姩澶嶅埗leader锛屼笉鎻愪緵璇诲啓锛堜富瑕佷繚璇佸鍓湰鏁版嵁鍜屾秷璐圭殑涓€鑷存€э級銆傚鏋渓eader鎵€鍦ㄧ殑broker鎸備簡锛岄偅涔堝氨浼氳繘琛屼竴娆℃柊鐨刲eader閫変妇銆傛潃姝籰eader鍚庯紝鏌ョ湅topic鐘舵€侊細killtheleader
ps-aux|grepserver.properties
kill17631
鏌ョ湅涓婚鐘舵€?br/>./kafka-topics.sh--describe--zookeeper172.16.253.35:2181--topicmy-replicated-topicisr:The鍙互鍚屾鐨刡roker鑺傜偣鍜屽凡缁忓悓姝ョ殑broker鑺傜偣瀛樻斁鍦╥sr闆嗗悎涓€?.broker銆乼opic銆乸artitions銆乺eplicaskafka闆嗙兢鐢卞涓猙roker缁勬垚銆備唬鐞嗗瓨鍌ㄤ富棰樼殑涓嶅悓鍒嗗尯鈥斺€斿壇鏈€?.Kafka闆嗙兢娑堟伅鍙戦€?/kafka-console-producer.sh--broker-list172.16.253.38:9092,172.16.253.38:9093,172.16.253.38:9094--topicmy-replicated-topic
kill棰嗗鑰?br/>ps-aux|grepserver.properties
kill17631
鏌ョ湅topic鎯呭喌
./kafka-topics.sh--describe--zookeeper172.16.253.35:2181--topicmyreplicated-topic5.kafka闆嗙兢娑堟伅娑堣垂./kafka-console-consumer.sh--bootstrap-server172.16.253.38:9092,172.16.253.38:9093,172.16.253.38:9094--from-beginning--topicmy-replicated-topic6.鍒嗗尯娑堣垂鑰呯粍娑堣垂鑰呰鎯呭浘涓殑Kafka闆嗙兢鏈変袱涓猙roker锛屾瘡涓猙roker涓湁澶氫釜partition銆備竴涓猵artition鍙兘琚竴涓猚onsumergroup涓殑鏌愪釜consumer娑堣垂锛屼粠鑰屼繚璇佷簡娑堣垂鐨勯『搴忋€侹afka鍙繚璇乸artition鑼冨洿鍐呯殑灞€閮ㄦ秷鎭秷璐归『搴忥紝涓嶈兘淇濊瘉鍚屼竴涓猼opic鍦ㄥ涓猵artition涓殑鏁翠綋娑堣垂椤哄簭銆備竴涓秷璐硅€呭彲浠ユ秷璐瑰涓垎鍖恒€備竴涓秷璐圭粍涓殑娑堣垂鑰呮暟閲忎笉鑳借秴杩囦竴涓富棰樹腑鍒嗗尯鐨勬暟閲忥紝鍚﹀垯澶氬嚭鐨勬秷璐硅€呮棤娉曟秷璐规秷鎭€傛湰鏂囧弬涓庢€濈淮绉戞妧璁烘枃寰侀泦锛屾鍦ㄩ槄璇荤殑鏈嬪弸娆㈣繋鍔犲叆銆?/p>
