abhidtu / emqttd_publish_client_activity

Publish MQTT client's activity (message ack, publish, subscribe, unsubscribe, connect, disconnect) to a SYSTEM/# channels with configurable QoS
MIT License
6 stars 0 forks source link

what's your plan about integrating kafka #1

Open libfetion opened 8 years ago

libfetion commented 8 years ago

you have added kakfka dependency.

Do you have plan to finish it to resend the data to kafka's topic directly?

abhidtu commented 8 years ago

Hi @libfetion : I was working on on integrating it with kafka, i am using this dependency https://github.com/helpshift/ekaf but i'm unable to get this Erlang kafka client working in this project. Currently i'm struck in some other task so not able to devote time for this kafka integration. As of now i'm using an intermediate java mqtt subscriber which listens on SYSTEM/# channels an publishes them similar kafka topics. Would you like to fork the project and add this functionality.