search

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

client 生产消息未携带时间戳 #135

Open firefliesx opened 2 years ago

firefliesx commented 2 years ago

produce.lua line65 request.API_VERSION_V1 应该修改为手动传入的 self.api_version, 否则在 request.lua line 241 处的 message_version 为 0， request.lua line 194 message_package 不会走有时间戳的分支，导致没有生产的消息没有时间戳。

fireflyhoo commented 2 years ago

好人啊,可行

doujiang24 commented 2 years ago

@firefliesx 👍🏻 欢迎贡献 PR~

firefliesx commented 2 years ago

@doujiang24 好的，马上提 PR