如何在网页中发送kafka消息

// 引入KafkaJS库
const { Kafka } = require('kafkajs');

// 创建Kafka客户端实例
const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['kafka1:9092', 'kafka2:9092'] // Kafka集群的地址和端口号
});

// 创建生产者实例
const producer = kafka.producer();

// 定义发送消息的函数
async function sendKafkaMessage(topic, message) {
  try {
    // 连接到Kafka集群
    await producer.connect();

    // 发送消息
    await producer.send({
      topic: topic,
      messages: [
        { value: message }
      ]
    });

    console.log('消息发送成功');
  } catch (error) {
    console.error('发送消息失败', error);
  } finally {
    // 断开与Kafka集群的连接
    await producer.disconnect();
  }
}

// 调用发送消息的函数
sendKafkaMessage('my-topic', 'Hello Kafka!');