Skip to content

simingwang/emqx-plugin-kafkav5

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

72 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

emqx-plugin-template

This is a template plugin for EMQX >= 5.0.

For EMQX >= 4.3, please see branch emqx-v4

For older EMQX versions, plugin development is no longer maintained.

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:

_build/default/emqx_plugrel/emqx_plugin_kafka-5.0.0.tar.gz

You can directly install above package to emqx5+ plugins dashboard, and following below guides to setup the env variables.

######kafka configure in /etc/profile set up kafka configuration in env file

export KAFKA_ADDRESS_LIST=192.168.1.1:9092,192.168.1.2:9092,192.168.1.3:9092
export KAFKA_TOPIC=mqtt-topic
export KAFKA_QUERY_API_VERSIONS=true
export KAFKA_RECONNECT_COOL_DOWN_SECONDS=10

If deploying emqx with build from source.

  1. need to set NIF_BIN_DIR to /usr/lib64
    text "export NIF_BIN_DIR = /ust/lib64" to /etc/profile
  2. put all plugin's *.so file to /usr/lib64

About

emqxv5-with-kafka-brod

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages