我使用的是kafka python==2.0.1
制作人.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'))

如何在消费者中获取时间戳\ ms值？