InitCSVLog initialises a CSVLOG plugin It does this by loading a config file if one can be found.

InitKafka Init kafka client.

LoadCSVLogConfig loads the configuration file - it currently looks in "./plugins/csvlog/csvlogconfig.json" (following the example of the default location of the kafka plugin config file) if it doesn't find it there it looks in two further places - the current directory and an "assets" folder under the current directory (This is for compatibility with a couple of deployed) implementations.

Connect mqtt connect.

Disconnect mqtt disconenct.

Kafka plugin name.

Publish mqtt publish.

Subscribe mqtt sub.

Unsubscribe mqtt sub.

Elements kafka publish elements.