lua-resty-kafka
lua-resty-kafka copied to clipboard
client 生产消息未携带时间戳
trafficstars
produce.lua line65 request.API_VERSION_V1 应该修改为手动传入的 self.api_version, 否则在 request.lua line 241 处的 message_version 为 0, request.lua line 194 message_package 不会走有时间戳的分支,导致没有生产的消息没有时间戳。
好人啊,可行
@firefliesx 👍🏻 欢迎贡献 PR~
@doujiang24 好的,马上提 PR