lua-resty-kafka icon indicating copy to clipboard operation
lua-resty-kafka copied to clipboard

resty.kafka.producer send not timestamp supported?

Open zq-2020 opened this issue 3 years ago • 2 comments
trafficstars

Hello, I produce messages by require "resty.kafka.producer" send. consumer use kafka-python. consumer.offsets_for_times({topic_partition: timestamp}) return offset is always None. But if send in other ways, offsets_for_times return correct offset.

zq-2020 avatar May 24 '22 06:05 zq-2020

chang this code

image

to

image

and set api_version init

image

fireflyhoo avatar May 26 '22 08:05 fireflyhoo

@fireflyhoo Thanks!

zq-2020 avatar May 26 '22 09:05 zq-2020