{"repo":"nananatsu/emqx_plugin_kafka","free":true,"listed":false,"github":"https://github.com/nananatsu/emqx_plugin_kafka","clone":"git clone https://github.com/nananatsu/emqx_plugin_kafka.git","description":"kafka plugin for emqx ~5.1","language":"Erlang","stars":14,"topics":["emqx","kafka"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"emqx-plugin-kafka This is a kafka plugin for EMQX = 5.1 (test for 5.8.7) . 代码说明 Release A EMQX plugin release is a zip package including 1. A JSON format metadata file 2. A tar file with plugin's apps packed Execute make rel to have the package created like: See EMQX documents for details on how to deploy the plugin. Plugin read config from /opt/emqx/etc/emqx plugin kafka.conf, exmple: kafka { ## required client { ## required client id = \"emqx kafka\" ## required servers = [ \"localhost:9092\" ] ## allow: per partition per broker ## default: per partition connection strategy = per partition ## unit: ms ## default: 5000 min metadata refresh interval = 5000 ## allow: boolean ## default: true query api versions = true ## unit: ms ## default: 240000 request timeout = 240000 ## optional ## sasl { ## ## allow: plain scram sha 256 scram sha 512 ## mechanism = plain ## username = \"username\" ## password = \"password\" ## } ## optional ## ssl { ## ## allow: verify none verify none ## verify = verify none ## ca cert file = \"/etc/ssl/cert.pem\" ## depth = 3 ## ## enable support for common wildcard certificates ## customize hostname check = true ## } } ## required ## global kafka producer config producer { ## allow: sync async ## default: sync produce = sync ## unit: ms ## default: 3000 produce sync timeout = 3000 ## mqtt payload encode for kafak ## allow: plain base64 ## default: plain encode payload type = plain ## Base directory for replayq to store messages on disk ## default: undefined rep","default_branch":null,"files":null,"tree":[],"storefront":"/r/nananatsu","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/nananatsu/emqx_plugin_kafka/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}