如何使用nodejs为kafka 10消息添加时间戳

const kafka = require('kafka-node');

const client = new kafka.KafkaClient({ kafkaHost: 'kafka服务器地址:9092' });
const producer = new kafka.Producer(client);

const timestamp = Date.now();
const payloads = [
  {
    topic: 'topic名称',
    messages: [
      { value: '消息内容', timestamp: timestamp }
    ]
  }
];

producer.send(payloads, (error, data) => {
  if (error) {
    console.error('发送消息失败：', error);
  } else {
    console.log('消息发送成功：', data);
  }
});