search

doujiang24 / lua-resty-kafka

Lua kafka client driver for the Openresty based on the cosocket API
BSD 3-Clause "New" or "Revised" License
804 stars 275 forks source link

In code demo： #14

Closed yanbit closed 8 years ago

yanbit commented 8 years ago

-- this is async producer_type and bp will be reused in the whole nginx worker local bp = producer:new(broker_list, { producer_type = "async" }) local ok, err = p:send("test", key, message)

p == bp

this should be bp:send("test", key, message)

doujiang24 commented 8 years ago

@yanbit Thanks for your report