I want to add kafka header application/json information

doujiang24 / lua-resty-kafka

Lua kafka client driver for the Openresty based on the cosocket API

BSD 3-Clause "New" or "Revised" License

801 stars 274 forks source link

I want to add kafka header application/json information #141

Open paulsmile opened 2 years ago

paulsmile commented 2 years ago

I want to use lua kafka,just send key,message,times'tamp information, but I want to define application/json header in kafka, how could I add the code??

paulsmile commented 2 years ago

Can add the kafka protocol 2.0 version in this lua-resty-kafka? @doujiang24