如何在节点js中写入jsonArray到kafka主题

const kafka = require('kafka-node');
const Producer = kafka.Producer;
const KeyedMessage = kafka.KeyedMessage;
const client = new kafka.KafkaClient();
const producer = new Producer(client);

const client = new kafka.KafkaClient({ kafkaHost: 'localhost:9092' });
const producer = new Producer(client);

const jsonArray = [{ id: 1, name: 'Alice' }, { id: 2, name: 'Bob' }];
const jsonStr = JSON.stringify(jsonArray);
const payloads = [{ topic: 'myTopic', messages: jsonStr }];
producer.send(payloads, function(err, data) {
    if (err) {
        console.log('发送消息失败：', err);
    } else {
        console.log('消息发送成功：', data);
    }
});