KoP 姝e紡寮€婧愶細鍦?Apache Pulsar 涓婃敮鎸佸師鐢?Kafka 鍗忚
Posted ApachePulsar
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了KoP 姝e紡寮€婧愶細鍦?Apache Pulsar 涓婃敮鎸佸師鐢?Kafka 鍗忚相关的知识,希望对你有一定的参考价值。
馃帣锔忛槄璇绘湰鏂囬渶 10 鍒嗛挓
鎴戜滑寰堥珮鍏村湴瀹e竷 StreamNative 鍜?OVHcloud 寮€婧愪簡 KoP锛圞afka on Pulsar锛夈€?/span>KoP 灏?Kafka 鍗忚澶勭悊鎻掍欢寮曞叆 Pulsar broker銆傝繖鏍蜂竴鏉ワ紝Apache Pulsar 灏辨敮鎸佸師鐢?Apache Kafka 鍗忚銆?/span>
灏?KoP 鍗忚澶勭悊鎻掍欢娣诲姞鍒扮幇鏈?Pulsar 闆嗙兢鍚庯紝鐢ㄦ埛涓嶇敤淇敼浠g爜灏卞彲浠ュ皢鐜版湁鐨?Kafka 搴旂敤绋嬪簭鍜屾湇鍔¤縼绉诲埌 Pulsar銆?/span>
杩欐牱锛孠afka 搴旂敤绋嬪簭灏卞彲浠ヤ娇鐢?Pulsar 鐨勫己澶у姛鑳斤紝渚嬪锛?/span>
鍒╃敤浼佷笟绾у绉熸埛鐗规€х畝鍖栬繍钀?/span>
閬垮厤鏁版嵁鎼縼锛岀畝鍖栨搷浣?/span>
鍒╃敤 Apache BookKeeper 鍜屽垎灞傚瓨鍌ㄦ寔涔呬繚鐣欎簨浠舵祦
鍒╃敤 Pulsar Functions 杩涜鏃犳湇鍔″櫒鍖栦簨浠跺鐞?/span>
Apache Pulsar 鏄竴涓簨浠舵祦骞冲彴銆傛渶鍒濓紝Apache Pulsar 灏遍噰鐢ㄤ簯鍘熺敓銆佸垎灞傚垎鐗囩殑鏋舵瀯銆傝鏋舵瀯灏嗘湇鍔″拰瀛樺偍鍒嗙寮€鏉ワ紝浣跨郴缁熷疄鐜版洿鍙嬪ソ鐨勫鍣ㄥ寲銆?/span>
Pulsar 鐨勪簯鍘熺敓鏋舵瀯鍏峰寮烘墿灞曟€с€侀珮涓€鑷存€у拰楂樺脊鎬э紝浣垮叕鍙歌兘閫氳繃瀹炴椂鏁版嵁瑙e喅鏂规鎵╁睍涓氬姟銆傝嚜 2016 骞村紑婧愪互鏉ワ紝Pulsar 宸插緱鍒板箍娉涢噰鐢紝骞朵簬 2018 骞存垚涓?Apache 椤剁骇椤圭洰銆?/span>
Plusar 涓洪槦鍒楀拰娴佸伐浣滆礋杞芥彁渚涚粺涓€鐨勬秷鎭ā鍨嬨€侾ulsar 鏀寔鑷繁鍩轰簬 protobuf 鐨勪簩杩涘埗鍗忚锛屼互纭繚楂樻€ц兘鍜屼綆寤惰繜銆俻rotobuf 鏈夊埄浜庡疄鐜?Pulsar 瀹㈡埛绔€?/span>
鑰屼笖锛岃椤圭洰涔熸敮鎸?Java锛孏o锛孭ython 鍜?C ++ 璇█浠ュ強绀惧尯鎻愪緵鐨勭涓夋柟瀹㈡埛绔€備絾鏄紝瀵逛簬浣跨敤鍏朵粬娑堟伅浼犺緭鍗忚缂栧啓鐨勫簲鐢ㄧ▼搴忥紝鐢ㄦ埛蹇呴』閲嶅啓杩欎簺搴旂敤绋嬪簭锛屽惁鍒欒繖浜涘簲鐢ㄧ▼搴忔棤娉曢噰鐢?Pulsar 鏂扮殑缁熶竴娑堟伅浼犺緭鍗忚銆?/span>
涓轰簡瑙e喅杩欎竴闂锛孭ulsar 绀惧尯寮€鍙戜簡涓€浜涘簲鐢ㄧ▼搴忥紝浠ヤ究灏?Kafka 搴旂敤绋嬪簭浠庡叾浠栨秷鎭郴缁熻縼绉诲埌 Pulsar銆備緥濡傦紝Pulsar 鍦?Kafka Java API 涓婃彁渚涗簡 Kafka wrapper銆?/span>
Kafka wrapper 鍏佽鐢ㄦ埛鍦ㄤ笉鏀瑰彉浠g爜鐨勬儏鍐典笅灏嗗叾浣跨敤鐨?Kafka Java 瀹㈡埛绔簲鐢ㄧ▼搴忎粠 Kafka 鍒囨崲鍒?Pulsar銆侾ulsar 杩樻彁渚涗赴瀵岀殑 connector 鐢熸€佺郴缁燂紝鐢ㄤ簬杩炴帴 Pulsar 鍜屽叾浠栨暟鎹郴缁熴€?/span>
浣嗘槸锛岄偅浜涙兂瑕佷粠鍏朵粬 Kafka 搴旂敤绋嬪簭鍒囨崲鍒?Pulsar 鐨勭敤鎴蜂粛鐒舵湁寮虹儓鐨勯渶姹傘€?/span>
StreamNative 鍜?nbsp;OVHcloud 鍚堜綔
StreamNative 鏀跺埌澶ч噺鐨勫叆绔欒姹傦紝璇锋眰甯姪浠庡叾浠栨秷鎭郴缁熻縼绉诲埌 Pulsar 銆傚悓鏃讹紝StreamNative 涔熸剰璇嗗埌鍦?Pulsar 涓婂師鐢熸敮鎸佸叾浠栨秷鎭紶杈撳崗璁紙渚嬪 AMQP 鍜?Kafka锛夌殑蹇呰鎬с€?/span>
鎵€浠ワ紝StreamNative 寮€濮嬭嚧鍔涗簬灏嗛€氱敤鍗忚澶勭悊鎻掍欢妗嗘灦寮曞叆鍒?Pulsar 涓€傝妗嗘灦鍏佽浣跨敤鍏朵粬娑堟伅浼犺緭鍗忚鐨勫紑鍙戜汉鍛樹娇鐢?Pulsar銆?/span>
澶氬勾鏉ワ紝OVHcloud 涓€鐩撮噰鐢?Apache Kafka銆?/span>
灏界浠栦滑鏈夊湪 Kafka 涓婅繍琛屽涓泦缇や笖姣忕澶勭悊鏁扮櫨涓囨潯娑堟伅鐨勭粡楠岋紝浣嗕粛闈复鑹板法鐨勮繍钀ユ寫鎴樸€備緥濡傦紝濡傛灉涓嶄娇鐢ㄥ绉熸埛鐗规€э紝浠栦滑寰堥毦灏嗘垚鍗冧笂涓囦釜鐢ㄦ埛鐨勬暟鍗冧釜 Topic 鏀惧湪涓€涓泦缇や腑銆?/span>
鎵€浠ワ紝OVHcloud 鏀惧純 Kafka锛屽喅瀹氬皢鍏朵富棰樺嵆鏈嶅姟鐨勪骇鍝侊紙鍗?ioStream锛夎浆绉诲埌 Pulsar锛屽苟鍦?Pulsar 涓婃瀯寤哄叾浜у搧銆?/strong>涓?Kafka 鐩告瘮锛孭ulsar 鏀寔澶氱鎴风壒鎬т笖鍏舵暣浣撴灦鏋勫寘鍚?Apache BookKeep 缁勪欢锛岃繖鏈夊姪浜庣畝鍖栫敤鎴锋搷浣溿€?/span>
鍦ㄥ垵姝ュ疄楠屼箣鍚庯紝OVHcloud 鍐冲畾灏?KoP 浣滀负 PoC proxy锛屽皢 Kafka 鍗忚鍗虫椂杞崲鍒?Pulsar銆傚湪姝よ繃绋嬩腑锛孫VHcloud 娉ㄦ剰鍒?StreamNative 姝e湪鑷村姏浜庡皢 Kafka 鍗忚鍘熺敓鍦板紩鍏ュ埌 Pulsar銆備簬鏄紝浠栦滑鑱旀墜寮€鍙戜簡 KoP銆?/span>
KoP 鏃ㄥ湪鍒╃敤 Pulsar 鍜?BookKeeper 鐨勪簨浠舵祦瀛樺偍鏋舵瀯鍜?Pulsar 鐨勫彲鎻掓嫈鍗忚澶勭悊鎻掍欢妗嗘灦鏉ユ彁渚涗竴绉嶇簿绠€鑰屽叏闈㈢殑瑙e喅鏂规銆?/span>
KoP 鏄竴涓崗璁悕绉颁负銆宬afka銆嶇殑鍗忚澶勭悊鎻掍欢銆侹oP 缁戝畾鍦?Pulsar broker涓婏紝骞朵笌 Pulsar broker 涓€璧疯繍琛屻€?/span>
鍏充簬鏃ュ織锛孭ulsar 鍜?Kafka 閮介噰鐢ㄩ潪甯哥浉浼肩殑鏁版嵁妯″瀷锛岀敤浜庡彂甯?璁㈤槄娑堟伅鍜屼簨浠舵祦銆備緥濡傦紝Pulsar 鍜?Kafka 閮介噰鐢ㄥ垎甯冨紡鏃ュ織銆?/span>
杩欎袱涓郴缁熺殑涓昏鍖哄埆鍦ㄤ簬瀹冧滑濡備綍瀹炵幇鍒嗗竷寮忔棩蹇椼€侹afka 閲囩敤鍒嗗尯鐨勬灦鏋勶紝灏嗗垎甯冨紡鏃ュ織锛圞afka 鍒嗗尯涓殑鏃ュ織锛夊瓨鍌ㄥ湪涓€缁?broker 涓€侾ulsar 閲囩敤鍒嗙墖鐨勬灦鏋勶紝鍒╃敤 Apache BookKeeper 浣滀负鍏舵í鍚戞墿灞曠殑鍒嗙墖瀛樺偍灞傦紝灏嗗垎甯冨紡鏃ュ織瀛樺偍鍦?Apache BookKeeper 涓€?/span>
Pulsar 鍩轰簬鍒嗙墖鐨勬灦鏋勬湁鍔╀簬閬垮厤鏁版嵁鎼縼銆佸疄鐜伴珮鎵╁睍鎬с€佷互鍙婃寔涔呭湴瀛樺偍浜嬩欢娴併€?/span>
Pulsar 鍜?Kafka 閮藉熀浜庣浉浼肩殑鏁版嵁妯″瀷锛堝垎甯冨紡鏃ュ織锛夎繘琛屾惌寤猴紝鑰屼笖 Pulsar 閲囩敤鍒嗗竷寮忔棩蹇楀瓨鍌ㄥ拰鍙彃鎷旂殑鍗忚澶勭悊鎻掍欢妗嗘灦锛堝湪2.5.0 鐗堟湰涓紩鍏ワ級锛屾墍浠?Pulsar 鍙互寰堝鏄撳湴瀹炵幇鍏煎 Kafka 鐨勫崗璁鐞嗘彃浠躲€?/span>
閫氳繃瀵规瘮 Pulsar 鍜?Kafka锛屾垜浠彂鐜拌繖涓ょ绯荤粺鏈夊緢澶氱浉浼间箣澶勩€傝繖涓ょ绯荤粺閮藉寘鎷互涓嬫搷浣滐細
-
Topic 鏌ユ壘
锛氭墍鏈夊鎴风閮借繛鎺ュ埌浠讳竴 broker 浠ユ煡鎵?Topic 鐨勫厓鏁版嵁锛堝嵆 owner broker锛夈€傝幏鍙栧厓鏁版嵁涔嬪悗锛屽鎴风涓?owner broker 寤虹珛鎸佷箙鐨?TCP 杩炴帴銆?/span>
-
鍙戝竷
锛氬鎴风涓?Topic 鍖虹殑 owner broker 杩涜瀵硅瘽锛屼互灏嗘秷鎭拷鍔犲埌
鍒嗗竷寮忔棩蹇?/span>
涓€?/span>
-
娑堣垂
锛氬鎴风涓?Topic 鍒嗗尯鐨?owner broker 杩涜瀵硅瘽锛屼互渚夸粠鍒嗗竷寮忔棩蹇椾腑璇诲彇娑堟伅銆?/span>
-
鍋忕Щ閲?/span>
锛氫负鍙戝竷缁?Topic 鍒嗗尯鐨勬秷鎭垎閰嶅亸绉婚噺銆傚湪 Pulsar 涓紝鍋忕Щ閲忚绉颁负 MessageId銆俢onsumer 鍙互浣跨敤鍋忕Щ閲忔潵鏌ユ壘鏃ュ織涓殑缁欏畾浣嶇疆锛屼互渚胯鍙栨秷鎭€?/span>
-
娑堣垂鐘舵€?/strong>
锛氳繖涓や釜绯荤粺閮界淮鎶よ闃呬腑鐨?consumer锛?Kafka 绉颁箣涓烘秷璐圭粍锛夌殑娑堣垂鐘舵€併€侹afka 灏嗘秷璐圭姸鎬佸瓨鍌ㄥ湪
`__offsets`
Topic锛岃€?Pulsar 灏嗘秷璐圭姸鎬佸瓨鍌ㄥ湪
`cursors`
銆?/span>
姝e浣犳墍瑙侊紝杩欎簺閮芥槸妯悜鎵╁睍鍒嗗竷寮忔棩蹇楀瓨鍌紙渚嬪 Apache BookKeeper锛夋彁渚涚殑鎵€鏈夊師濮嬫搷浣溿€?br>
Pulsar 鐨勬牳蹇冨姛鑳芥槸鍦?Apache BookKeeper 涓婂疄鐜扮殑銆傚洜姝わ紝鎴戜滑鍙互闈炲父绠€鍗曘€佺洿鎺ュ湴浣跨敤 Pulsar 鍦?BookKeeper 涓婂紑鍙戠殑鐜版湁缁勪欢鏉ュ疄鐜?Kafka 姒傚康銆?/span>
涓嬪浘璇存槑浜嗘垜浠浣曞湪 Pulsar 涓坊鍔?Kafka 鍗忚鏀寔銆傛垜浠紩鍏ヤ竴涓柊鐨?span>鍗忚澶勭悊鎻掍欢锛岃鍗忚澶勭悊鎻掍欢鍒╃敤 Pulsar 鐨勭幇鏈夌粍浠讹紙渚嬪 Topic 鍙戠幇銆佸垎甯冨紡鏃ュ織搴?ManagedLedger銆乧ursor 绛夛級鏉ュ疄鐜?Kafka 浼犺緭鍗忚銆?/span>
Kafka 灏嗘墍鏈?Topic 瀛樺偍鍦ㄦ墎骞崇殑鍛藉悕绌洪棿銆備絾鏄紝Pulsar 灏?Topic 瀛樺偍鍦ㄥ眰娆″寲銆佸绉熸埛鐨勫懡鍚嶇┖闂淬€傛垜浠湪 broker 閰嶇疆涓坊鍔犱簡
`kafkaNamespace`
閰嶇疆锛岃繖鏍风鐞嗗憳灏卞彲浠ュ皢 Kafka Topic 鏄犲皠鍒?Pulsar Topic銆?/span>
涓轰簡鏂逛究 Kafka 鐢ㄦ埛浣跨敤 Apache Pulsar 鐨勫绉熸埛鐗规€э紝褰?Kafka 鐢ㄦ埛浣跨敤 SASL 楠岃瘉鏈哄埗鏉ラ獙璇?Kafka 瀹㈡埛绔殑鏃跺€欙紝鍙互鎸囧畾涓€涓?Pulsar 绉熸埛鍜屽懡鍚嶇┖闂翠綔涓哄叾 SASL 鐢ㄦ埛鍚嶃€?/span>
馃攷娑堟伅 ID 鍜屽亸绉婚噺
Kafka 涓烘瘡鏉¤鎴愬姛鍙戝竷鍒?Topic 鍒嗗尯鐨勬秷鎭兘鎸囧畾浜嗕竴涓亸绉婚噺銆侾ulsar 涓烘瘡鏉℃秷鎭寚瀹氫簡涓€涓?
`MessageID`
銆傛秷鎭?ID 鐢?
`ledger-id`
銆?
`entry-id`
鍜?
`batch-index`
缁勬垚銆傛垜浠湪 Pulsar-Kafka wrapper 涓娇鐢ㄧ浉鍚岀殑鏂规硶灏?Pulsar 鐨勬秷鎭?ID 杞崲涓哄亸绉婚噺锛屽弽涔嬩害鐒躲€?/span>
Kafka 鍜?Pulsar 鐨勬秷鎭兘鍖呭惈閿€佸€笺€佹椂闂存埑鍜?header锛堝湪 Pulsar 涓绉颁綔 鈥榩roperties鈥欙級銆傛垜浠嚜鍔ㄥ湪 Kafka 娑堟伅鍜?Pulsar 娑堟伅涔嬮棿杞崲杩欎簺瀛楁銆?/span>
馃攷Topic 鏌ユ壘
鎴戜滑涓?Kafka 鍜?Pulsar 鐨勮姹傚鐞嗘彃浠舵彁渚涚浉鍚岀殑 Topic 鏌ユ壘鏂规硶銆傝姹傚鐞嗘彃浠跺彂鐜?Topic锛屾煡鎵炬墍璇锋眰鐨?Topic 鍒嗗尯鐨勫叏閮ㄦ墍鏈夋潈锛岀劧鍚庡皢鍖呭惈鎵€鏈夋潈淇℃伅鐨?Kafka `TopicMetadata` 杩斿洖缁?Kafka 瀹㈡埛绔€?/span>
馃攷鍙戝竷娑堟伅
褰撴敹鍒?Kafka 瀹㈡埛绔彂甯冪殑娑堟伅鍚庯紝Kafka 璇锋眰澶勭悊鎻掍欢閫愪竴灏嗗涓瓧娈碉紙渚嬪閿€佸€笺€佹椂闂存埑鍜?headers锛夎繘琛屾槧灏勶紝浠庤€屽皢 Kafka 娑堟伅杞崲涓?Pulsar 娑堟伅銆?/span>
鍚屾椂锛孠afka 璇锋眰澶勭悊鎻掍欢鍒╃敤 ManagedLedger append API 灏嗚繖浜涘凡杞寲鐨?Pulsar 娑堟伅瀛樺偍鍦?BookKeeper銆侹afka 璇锋眰澶勭悊鎻掍欢灏?Kafka 娑堟伅杞崲涓?Pulsar 娑堟伅鍚庯紝鐜版湁鐨?Pulsar 搴旂敤绋嬪簭灏卞彲浠ユ帴鏀?Kafka 瀹㈡埛绔彂甯冪殑娑堟伅銆?/span>
馃攷娑堣垂娑堟伅
褰撴敹鍒?Kafka 瀹㈡埛绔殑 consumer 璇锋眰鏃讹紝Kafka 璇锋眰澶勭悊鎻掍欢鎵撳紑涓€涓潪鎸佷箙 cursor锛岀劧鍚庝粠璇锋眰鐨勫亸绉婚噺寮€濮嬭鍙?entries銆?/span>
Kafka 璇锋眰澶勭悊鎻掍欢灏?Pulsar 娑堟伅杞崲鍥?Kafka 娑堟伅鍚庯紝鐜版湁鐨?Kafka 搴旂敤绋嬪簭灏卞彲浠ユ帴鏀?Pulsar 瀹㈡埛绔彂甯冪殑娑堟伅銆?/span>
馃攷Group coordinator & 鍋忕Щ閲忕鐞?/strong>
鏈€澶х殑鎸戞垬鏄疄鐜?group coordinator 鍜屽亸绉婚噺绠$悊銆侾ulsar 涓嶆敮鎸侀泦涓殑 group coordinator锛屾棤娉曚负娑堣垂缁勯噷鐨?consumer 鍒嗛厤鍒嗗尯锛屼篃鏃犳硶绠$悊姣忎釜娑堣垂缁勭殑鍋忕Щ閲忋€?/span>
Pulsar broker 鍩轰簬鍒嗗尯鏉ョ鐞嗗垎鍖哄垎閰嶏紝鑰屽垎鍖虹殑 owner broker 閫氳繃灏嗙‘璁や俊鎭瓨鍌ㄥ湪 cursors 鏉ョ鐞嗗亸绉婚噺銆?/span>
鎴戜滑寰堥毦璁?Pulsar 妯″瀷涓?Kafka 妯″瀷淇濇寔涓€鑷淬€傚洜姝わ紝涓轰簡瀹屽叏鍏煎 Kafka 瀹㈡埛绔紝鎴戜滑灏?coordinator group 鐨勬洿鏀瑰拰鍋忕Щ閲忓瓨鍌ㄥ湪 Pulsar 鍚嶄负
`public/kafka/__offsets`
绯荤粺 Topic 涓紝浠庤€屽疄鐜?Kafka coordinator group銆?/span>
杩欐牱锛屾垜浠兘澶熷湪 Pulsar 鍜?Kafka 涔嬮棿寤虹珛妗ユ锛屽苟鍏佽鐢ㄦ埛浣跨敤鐜版湁鐨?Pulsar 宸ュ叿鍜岀瓥鐣ユ潵绠$悊璁㈤槄骞剁洃鎺?Kafka consumer銆傛垜浠湪宸插疄鐜扮殑 coordinator group 涓坊鍔犱竴涓悗鍙扮嚎绋嬶紝瀹氭湡灏嗗亸绉婚噺鏇存柊浠庣郴缁?Topic 鍚屾鍒?Pulsar cursor銆?/span>
鍥犳锛屽疄闄呬笂 Kafka 娑堣垂缁勮璁や负鏄?Pulsar 璁㈤槄銆傛墍鏈夌幇鏈夌殑 Pulsar 宸ュ叿涔熷彲浠ョ敤浜庣鐞?Kafka 娑堣垂缁勩€?/span>
杩炴帴涓ょ娴佽鐨勬秷鎭敓鎬佺郴缁?/span>
StreamNative 鍜?OVHcloud 閮介噸瑙嗗鎴风殑鎴愬姛銆傛垜浠浉淇★紝鍦?Apache Pulsar 涓婃彁渚涘師鐢?Kafka 鍗忚鑳藉甯姪閲囩敤 Pulsar 鐨勭敤鎴锋洿蹇湴鍙栧緱涓氬姟鎴愬姛銆?/span>
KoP 鏁村悎浜嗕袱涓祦琛岀殑浜嬩欢娴佺敓鎬佺郴缁燂紝瑙i攣浜嗘柊鐨勭敤渚嬨€傚鎴峰彲浠ュ埄鐢ㄨ繖涓や釜鐢熸€佺郴缁熺殑浼樺娍锛屽€熷姪 Apache Pulsar 鏋勫缓涓€涓湡姝g粺涓€鐨勪簨浠舵祦骞冲彴锛屽姞閫熷紑鍙戝疄鏃跺簲鐢ㄧ▼搴忓拰鏈嶅姟銆?/span>
KoP 浣挎棩蹇楁敹闆嗗櫒鍙互缁х画浠庡叾鏉ユ簮鏀堕泦鏃ュ織鏁版嵁锛屽苟浣跨敤鐜版湁鐨?Kafka 闆嗘垚鍚?Apache Pulsar 鍙戝竷娑堟伅銆備笅娓稿簲鐢ㄧ▼搴忓彲浠ヤ娇鐢?Pulsar Functions 鏉ュ鐞嗗埌杈剧郴缁熺殑浜嬩欢锛屽疄鐜版棤鏈嶅姟鍣ㄥ寲浜嬩欢娴佷紶杈撱€?/span>
KoP 浣跨敤 Apache License V2 璁稿彲璇侊紝椤圭洰鍦板潃濡備笅銆?br>
馃敆https://github.com/streamnative/kop
StreamNative Platform 宸茬粡鍐呯疆 KoP銆備綘鍙互閫夋嫨涓嬭浇 StreamNative Platform鏉ヨ瘯鐢?KoP 鐨勬墍鏈夊姛鑳姐€?br>
馃敆http://streamnative.io/download
濡傛灉宸茬粡杩愯 Pulsar 闆嗙兢锛屽苟涓斿笇鏈涘叾鏀寔 Kafka 鍗忚锛屽彲浠ュ皢 KoP 鍗忚澶勭悊鎻掍欢瀹夎鍒扮幇鏈夌殑 Pulsar 闆嗙兢銆傜浉鍏宠缁嗕俊鎭紝璇峰弬鑰冨涓嬮摼鎺ヨ鏄?br>
馃敆http://streamnative.io/docs/latest/connect-and-ingest/kop/get-started -kop /锛僣onfigure
濡傛灉鎯宠浜嗚В鏈夊叧 KoP 鐨勬洿澶氫俊鎭紝璇峰弬鑰?KoP 鐨勪唬鐮佸拰鏂囨。淇℃伅銆?br>
鎴戜滑鏈熷緟浣犳彁鍑洪棶棰樺拰 PR銆備綘涔熷彲浠ュ湪 Pulsar Slack 涓姞鍏?
锛僰op
棰戦亾锛岃璁烘湁鍏?Kafka-on-Pulsar 鐨勬墍鏈変簨鎯呫€?br>
Slack 鐢宠锛?br>https://apache-pulsar.herokuapp.com/
鍚屾椂锛孲treamNative 鍜?OVHcloud 灏嗕簬
澶钩娲嬫椂闂?3 鏈?31 鏃?/span>
涓惧姙鏈夊叧 KoP 鐨勭綉缁滅爺璁ㄤ細銆傚鏋滄兂瑕佷簡瑙f洿澶氳缁嗕俊鎭紝鍙互鎵弿涓嬪浘浜岀淮鐮佽繘琛岀敵璇枫€傛湡寰呬笌浣犲湪缃戜笂瑙侀潰銆?/span>
鏈€鍒濓紝StreamNative 鍙戣捣 KoP 椤圭洰銆傚悗鏉ワ紝OVHcloud 鍥㈤槦鍔犲叆浜嗚椤圭洰銆傛垜浠竴璧峰悎浣滃紑鍙?KoP 椤圭洰銆?span>闈炲父鎰熻阿 OVHcloud 鐨?Pierre Zemb 鍜?Steven Le Roux 瀵硅繖涓」鐩殑璐$尞锛?/strong>
鎯宠闅忔椂鎺屾彙 Pulsar 鐨勭爺鍙戣繘灞曘€佺敤鎴锋渚嬪拰鐑偣璇濋鍚楋紵蹇潵鍏虫敞 Apache Pulsar 鍜?StreamNative 寰俊鍏紬鍙凤紝鎴戜滑绗竴鏃堕棿鍦ㄨ繖閲屽垎浜笌 Pulsar 鏈夊叧鐨勪竴鍒囥€?/span>
鐐逛釜鈥滃湪鐪嬧€濓紝鍒嗕韩鏇村绉戞妧鍐呭馃憞馃徎
以上是关于KoP 姝e紡寮€婧愶細鍦?Apache Pulsar 涓婃敮鎸佸師鐢?Kafka 鍗忚的主要内容,如果未能解决你的问题,请参考以下文章
mybatis涔嬫敞瑙e紡寮€鍙戜箣鍏宠仈鏌ヨ
姝e垯琛ㄨ揪寮忕殑浣跨敤
姝e垯琛ㄨ揪寮?java)瑙勫垯澶у叏
JS 姝e垯楠岃瘉瀛楃涓蹭腑鏄惁鍚湁鏁板瓧
webpack 3 姝e紡鍙戝竷锛岃浣犳洿鈥滃揩鈥?/h1>