lua-resty-kafka
lua-resty-kafka copied to clipboard
resty.kafka.producer send not timestamp supported?
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.
chang this code
to
and set api_version init
@fireflyhoo Thanks!