获取kafka使用者中的timestamp_ms值

问题描述

我正在使用kafka-python == 2.0.1

producer.py

def queue(self,key,value):
        self.producer.send(
            MESSAGES_TOPIC,timestamp_ms=int(time.mktime(datetime.utcNow().timetuple())),key=key,value=value,)

在timestamp_ms中，我添加了消息排队的时间。 在消费者中，我正在使用：

json.loads(event.body.decode('utf-8'))

如何在消费者中获得 timestamp_ms 的价值？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）