kafkajsruneachMessageisnotfetchingmessages

这个问题通常是由于未正确设置消费者组和主题分区所致。在kafkajs中，每个消费者必须加入消费者组并订阅主题分区才能接收到消息。

以下是一个kafkajs消费者的示例代码：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({ clientId: 'my-app', brokers: ['localhost:9092'] })

const consumer = kafka.consumer({ groupId: 'my-group' })

const run = async () => { await consumer.connect() await consumer.subscribe({ topic: 'my-topic', fromBeginning: true })

await consumer.run({ eachMessage: async ({ topic, partition, message }) => { console.log({ value: message.value.toString(), }) }, }) }

run().catch(console.error)

请注意，此示例代码使用了my-group消费者组，并订阅了my-topic主题的分区，因此任何发送到该主题中的消息都将传递给“每条消息”回调函数并打印在控制台上。 如果您希望在消费者订阅主题之后才发送的消息也能被接收到，请将fromBeginning选项设置为false或省略该选项。

如果您的代码已经正确设置了消费者组和主题分区，但仍然无法正常工作，请尝试调试连接到Kafka集群并订阅主题的步骤，以确保您的代码没有错误。