KoP 姝ｅ紡寮€婧愶細鍦?Apache Pulsar 涓婃敮鎸佸師鐢?Kafka 鍗忚

Posted 2021-04-20 ApachePulsar

馃帣锔忛槄璇绘湰鏂囬渶 10 鍒嗛挓

鎴戜滑寰堥珮鍏村湴瀹ｅ竷 StreamNative 鍜?OVHcloud 寮€婧愪簡 KoP锛圞afka on Pulsar锛夈€?/span>KoP 灏?Kafka 鍗忚澶勭悊鎻掍欢寮曞叆 Pulsar broker銆傝繖鏍蜂竴鏉ワ紝Apache Pulsar 灏辨敮鎸佸師鐢?Apache Kafka 鍗忚銆?/span>

灏?KoP 鍗忚澶勭悊鎻掍欢娣诲姞鍒扮幇鏈?Pulsar 闆嗙兢鍚庯紝鐢ㄦ埛涓嶇敤淇敼浠ｇ爜灏卞彲浠ュ皢鐜版湁鐨?Kafka 搴旂敤绋嬪簭鍜屾湇鍔¤縼绉诲埌 Pulsar銆?/span>

杩欐牱锛孠afka 搴旂敤绋嬪簭灏卞彲浠ヤ娇鐢?Pulsar 鐨勫己澶у姛鑳斤紝渚嬪锛?/span>

• 鍒╃敤浼佷笟绾у绉熸埛鐗规€х畝鍖栬繍钀?/span>

• 閬垮厤鏁版嵁鎼縼锛岀畝鍖栨搷浣?/span>

• 鍒╃敤 Apache BookKeeper 鍜屽垎灞傚瓨鍌ㄦ寔涔呬繚鐣欎簨浠舵祦

• 鍒╃敤 Pulsar Functions 杩涜鏃犳湇鍔″櫒鍖栦簨浠跺鐞?/span>

  
  

  ---

  
  

浠€涔堟槸 Apache Pulsar

Apache Pulsar 鏄竴涓簨浠舵祦骞冲彴銆傛渶鍒濓紝Apache Pulsar 灏遍噰鐢ㄤ簯鍘熺敓銆佸垎灞傚垎鐗囩殑鏋舵瀯銆傝鏋舵瀯灏嗘湇鍔″拰瀛樺偍鍒嗙寮€鏉ワ紝浣跨郴缁熷疄鐜版洿鍙嬪ソ鐨勫鍣ㄥ寲銆?/span>

Pulsar 鐨勪簯鍘熺敓鏋舵瀯鍏峰寮烘墿灞曟€с€侀珮涓€鑷存€у拰楂樺脊鎬э紝浣垮叕鍙歌兘閫氳繃瀹炴椂鏁版嵁瑙ｅ喅鏂规鎵╁睍涓氬姟銆傝嚜 2016 骞村紑婧愪互鏉ワ紝Pulsar 宸插緱鍒板箍娉涢噰鐢紝骞朵簬 2018 骞存垚涓?Apache 椤剁骇椤圭洰銆?/span>

瀵?KoP 鐨勬复鏈?/span>

Plusar 涓洪槦鍒楀拰娴佸伐浣滆礋杞芥彁渚涚粺涓€鐨勬秷鎭ā鍨嬨€侾ulsar 鏀寔鑷繁鍩轰簬 protobuf 鐨勪簩杩涘埗鍗忚锛屼互纭繚楂樻€ц兘鍜屼綆寤惰繜銆俻rotobuf 鏈夊埄浜庡疄鐜?Pulsar 瀹㈡埛绔€?/span>

鑰屼笖锛岃椤圭洰涔熸敮鎸?Java锛孏o锛孭ython 鍜?C ++ 璇█浠ュ強绀惧尯鎻愪緵鐨勭涓夋柟瀹㈡埛绔€備絾鏄紝瀵逛簬浣跨敤鍏朵粬娑堟伅浼犺緭鍗忚缂栧啓鐨勫簲鐢ㄧ▼搴忥紝鐢ㄦ埛蹇呴』閲嶅啓杩欎簺搴旂敤绋嬪簭锛屽惁鍒欒繖浜涘簲鐢ㄧ▼搴忔棤娉曢噰鐢?Pulsar 鏂扮殑缁熶竴娑堟伅浼犺緭鍗忚銆?/span>

涓轰簡瑙ｅ喅杩欎竴闂锛孭ulsar 绀惧尯寮€鍙戜簡涓€浜涘簲鐢ㄧ▼搴忥紝浠ヤ究灏?Kafka 搴旂敤绋嬪簭浠庡叾浠栨秷鎭郴缁熻縼绉诲埌 Pulsar銆備緥濡傦紝Pulsar 鍦?Kafka Java API 涓婃彁渚涗簡 Kafka wrapper銆?/span>

Kafka wrapper 鍏佽鐢ㄦ埛鍦ㄤ笉鏀瑰彉浠ｇ爜鐨勬儏鍐典笅灏嗗叾浣跨敤鐨?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 姝ｅ湪鑷村姏浜庡皢 Kafka 鍗忚鍘熺敓鍦板紩鍏ュ埌 Pulsar銆備簬鏄紝浠栦滑鑱旀墜寮€鍙戜簡 KoP銆?/span>

KoP 鏃ㄥ湪鍒╃敤 Pulsar 鍜?BookKeeper 鐨勪簨浠舵祦瀛樺偍鏋舵瀯鍜?Pulsar 鐨勫彲鎻掓嫈鍗忚澶勭悊鎻掍欢妗嗘灦鏉ユ彁渚涗竴绉嶇簿绠€鑰屽叏闈㈢殑瑙ｅ喅鏂规銆?/span> KoP 鏄竴涓崗璁悕绉颁负銆宬afka銆嶇殑鍗忚澶勭悊鎻掍欢銆侹oP 缁戝畾鍦?Pulsar broker涓婏紝骞朵笌 Pulsar broker 涓€璧疯繍琛屻€?/span>

---

鍒嗗竷寮忔棩蹇?/strong>

鍏充簬鏃ュ織锛孭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>

姝ｅ浣犳墍瑙侊紝杩欎簺閮芥槸妯悜鎵╁睍鍒嗗竷寮忔棩蹇楀瓨鍌紙渚嬪 Apache BookKeeper锛夋彁渚涚殑鎵€鏈夊師濮嬫搷浣溿€?br>
Pulsar 鐨勬牳蹇冨姛鑳芥槸鍦?Apache BookKeeper 涓婂疄鐜扮殑銆傚洜姝わ紝鎴戜滑鍙互闈炲父绠€鍗曘€佺洿鎺ュ湴浣跨敤 Pulsar 鍦?BookKeeper 涓婂紑鍙戠殑鐜版湁缁勪欢鏉ュ疄鐜?Kafka 姒傚康銆?/span>

涓嬪浘璇存槑浜嗘垜浠浣曞湪 Pulsar 涓坊鍔?Kafka 鍗忚鏀寔銆傛垜浠紩鍏ヤ竴涓柊鐨?span>鍗忚澶勭悊鎻掍欢锛岃鍗忚澶勭悊鎻掍欢鍒╃敤 Pulsar 鐨勭幇鏈夌粍浠讹紙渚嬪 Topic 鍙戠幇銆佸垎甯冨紡鏃ュ織搴?ManagedLedger銆乧ursor 绛夛級鏉ュ疄鐜?Kafka 浼犺緭鍗忚銆?/span>

馃攷Topic

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 鏁村悎浜嗕袱涓祦琛岀殑浜嬩欢娴佺敓鎬佺郴缁燂紝瑙ｉ攣浜嗘柊鐨勭敤渚嬨€傚鎴峰彲浠ュ埄鐢ㄨ繖涓や釜鐢熸€佺郴缁熺殑浼樺娍锛屽€熷姪 Apache Pulsar 鏋勫缓涓€涓湡姝ｇ粺涓€鐨勪簨浠舵祦骞冲彴锛屽姞閫熷紑鍙戝疄鏃跺簲鐢ㄧ▼搴忓拰鏈嶅姟銆?/span>

KoP 浣挎棩蹇楁敹闆嗗櫒鍙互缁х画浠庡叾鏉ユ簮鏀堕泦鏃ュ織鏁版嵁锛屽苟浣跨敤鐜版湁鐨?Kafka 闆嗘垚鍚?Apache Pulsar 鍙戝竷娑堟伅銆備笅娓稿簲鐢ㄧ▼搴忓彲浠ヤ娇鐢?Pulsar Functions 鏉ュ鐞嗗埌杈剧郴缁熺殑浜嬩欢锛屽疄鐜版棤鏈嶅姟鍣ㄥ寲浜嬩欢娴佷紶杈撱€?/span>

璇曠敤 KoP

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>

• 浠ｇ爜锛歨ttps://github.com/streamnative/kop

• 鏂囨。锛歨ttp://streamnative.io/docs/latest/connect-and-ingest/kop/overview-kop

鎴戜滑鏈熷緟浣犳彁鍑洪棶棰樺拰 PR銆備綘涔熷彲浠ュ湪 Pulsar Slack 涓姞鍏? 锛僰op  棰戦亾锛岃璁烘湁鍏?Kafka-on-Pulsar 鐨勬墍鏈変簨鎯呫€?br> Slack 鐢宠锛?br>https://apache-pulsar.herokuapp.com/

鍚屾椂锛孲treamNative 鍜?OVHcloud 灏嗕簬 澶钩娲嬫椂闂?3 鏈?31 鏃?/span> 涓惧姙鏈夊叧 KoP 鐨勭綉缁滅爺璁ㄤ細銆傚鏋滄兂瑕佷簡瑙ｆ洿澶氳缁嗕俊鎭紝鍙互鎵弿涓嬪浘浜岀淮鐮佽繘琛岀敵璇枫€傛湡寰呬笌浣犲湪缃戜笂瑙侀潰銆?/span>

---

鑷?璋?/span>

鏈€鍒濓紝StreamNative 鍙戣捣 KoP 椤圭洰銆傚悗鏉ワ紝OVHcloud 鍥㈤槦鍔犲叆浜嗚椤圭洰銆傛垜浠竴璧峰悎浣滃紑鍙?KoP 椤圭洰銆?span>闈炲父鎰熻阿 OVHcloud 鐨?Pierre Zemb 鍜?Steven Le Roux 瀵硅繖涓」鐩殑璐＄尞锛?/strong>

鎯宠闅忔椂鎺屾彙 Pulsar 鐨勭爺鍙戣繘灞曘€佺敤鎴锋渚嬪拰鐑偣璇濋鍚楋紵蹇潵鍏虫敞 Apache Pulsar 鍜?StreamNative 寰俊鍏紬鍙凤紝鎴戜滑绗竴鏃堕棿鍦ㄨ繖閲屽垎浜笌 Pulsar 鏈夊叧鐨勪竴鍒囥€?/span>

鐐逛釜鈥滃湪鐪嬧€濓紝鍒嗕韩鏇村绉戞妧鍐呭馃憞馃徎