|
@@ -362,6 +362,7 @@ produce_kafka_payload(Key, Message) ->
|
|
?LOG_INFO("[KAFKA PLUGIN]Message = ~s~n",[MessageBody]),
|
|
?LOG_INFO("[KAFKA PLUGIN]Message = ~s~n",[MessageBody]),
|
|
Payload = iolist_to_binary(MessageBody),
|
|
Payload = iolist_to_binary(MessageBody),
|
|
brod:produce_cb(emqx_repost_worker, Topic, hash, Key, Payload, fun(_,_) -> ok end),
|
|
brod:produce_cb(emqx_repost_worker, Topic, hash, Key, Payload, fun(_,_) -> ok end),
|
|
|
|
+ brod:produce_cb(emqx_repost_worker, "lamp_log_test", hash, Key, Payload, fun(_,_) -> ok end),
|
|
ok.
|
|
ok.
|
|
|
|
|
|
ntoa({0, 0, 0, 0, 0, 16#ffff, AB, CD}) ->
|
|
ntoa({0, 0, 0, 0, 0, 16#ffff, AB, CD}) ->
|