EMQ（杭州映云科技有限公司）是一家開源物聯(lián)網(wǎng)數(shù)據(jù)基礎(chǔ)設(shè)施軟件供應(yīng)商索绪，交付全球領(lǐng)先的開源 MQTT 消息服務(wù)器和流處理數(shù)據(jù)庫。
發(fā)簡信
IP屬地：廣東
-
-
@Cherron 好的漠其，謝謝哈嘴高！
Centos7 搭建v2.3.11 emq broker及編寫kafka插件
背景： emq開源版集成了許多插件，但沒有提供kafka的和屎。但官方提供了插件的模板拴驮，我們只需要照葫蘆畫瓢即可； 由于emq是基于Erlang編程語言柴信，所以我們需要搭建Erla...
-
@Cherron 我們這個topic太多了套啤，所以沒法手動注冊，目前對partition要求不嚴格随常，所以需要自動創(chuàng)建topic潜沦，在brod的github項目中https://github.com/klarna/brod/blob/master/src/brod.erl看到start_client（BootstrapEndpoints萄涯，ClientId，Config）方法的Config配置有auto_start_producers配置項唆鸡，這樣：
ClientConfig = [{auto_start_producers ,true}],
ok = brod:start_client(KafkaBootstrapEndpoints, brod_client_1, ClientConfig),
配置后發(fā)現(xiàn)還是會報上面的錯誤涝影，苦惱哦Centos7 搭建v2.3.11 emq broker及編寫kafka插件
背景： emq開源版集成了許多插件，但沒有提供kafka的争占。但官方提供了插件的模板燃逻，我們只需要照葫蘆畫瓢即可； 由于emq是基于Erlang編程語言燃乍，所以我們需要搭建Erla...
-
@Cherron 我用了您的這種方式來創(chuàng)建topic唆樊，發(fā)現(xiàn)在kafka沒有這個topic的時候會報錯：client 26236 disconnected, reason: {{badmatch,{error,unknown_topic_or_partition}},[{emq_plugin_kafka,on_message_publish,2,[{file,[115,114,99,47,101,109,113,95,112,108,117,103,105,110,95,107,97,102,107,97,46,101,114,108]},{line,134}]} ，請問是否有更好的方式能保證kafka沒有當(dāng)前mqtt的topic時也能正常創(chuàng)建kafka的topic并且發(fā)送消息給kafka刻蟹？我試了下并發(fā)情況確實比ekaf更好很多逗旁，謝謝!
Centos7 搭建v2.3.11 emq broker及編寫kafka插件
背景： emq開源版集成了許多插件，但沒有提供kafka的舆瘪。但官方提供了插件的模板片效，我們只需要照葫蘆畫瓢即可； 由于emq是基于Erlang編程語言英古，所以我們需要搭建Erla...
-
@Cherron 哦淀衣，我之前用ekaf的時候在ekaf_send方法中加入application:set_env(ekaf, ekaf_bootstrap_topics, Topic),這一句就會自動創(chuàng)建topic，不知道brod該怎么創(chuàng)建- -召调，我再研究下膨桥，還有按您寫的插件使用brod連接kafka能支持大概5000/s的并發(fā)嗎？感謝唠叛！
Centos7 搭建v2.3.11 emq broker及編寫kafka插件
背景： emq開源版集成了許多插件只嚣，但沒有提供kafka的。但官方提供了插件的模板艺沼，我們只需要照葫蘆畫瓢即可册舞； 由于emq是基于Erlang編程語言，所以我們需要搭建Erla...
-
Centos7 搭建v2.3.11 emq broker及編寫kafka插件背景： emq開源版集成了許多插件障般，但沒有提供kafka的调鲸。但官方提供了插件的模板，我們只需要照葫蘆畫瓢即可挽荡； 由于emq是基于Erlang編程語言藐石，所以我們需要搭建Erla...
-
-
@Cherron 謝謝哈贯钩，我現(xiàn)在也打算用brod試試，但是不知道brod怎么自動創(chuàng)建topic，不了解Erlang,設(shè)置了auto_start_producers為true還是沒用角雷，大佬能說下怎么自動創(chuàng)建topic嗎，因為我們需要emq的topic和kafka的topic保持一致
Centos7 搭建v2.3.11 emq broker及編寫kafka插件
背景： emq開源版集成了許多插件性穿，但沒有提供kafka的勺三。但官方提供了插件的模板，我們只需要照葫蘆畫瓢即可需曾； 由于emq是基于Erlang編程語言吗坚，所以我們需要搭建Erla...
-
ekaf：用jmeter測試發(fā)布消息并發(fā)，發(fā)現(xiàn)kafka收到的消息沒有并發(fā)數(shù)多呆万，請問作者有發(fā)現(xiàn)這個問題嗎商源，能給個解決方案嗎？謝謝谋减！
Centos7 搭建v2.3.11 emq broker及編寫kafka插件
背景： emq開源版集成了許多插件牡彻，但沒有提供kafka的。但官方提供了插件的模板出爹，我們只需要照葫蘆畫瓢即可庄吼； 由于emq是基于Erlang編程語言，所以我們需要搭建Erla...
