我的mqtt协议和emqttd开源项目个人理解(12)-Hook使用和连接Kafka发送消息,使用ekaf...
Payload=Message#mqtt_message.payload,Qos=Message#mqtt_message.qos,Dup=Message#mqtt_message.dup,Retain=Message#mqtt_message.retain,Timestamp=Message#mqtt_message.timestamp,ClientId=c(From),Username=u(From),Json=mochijson2:...