Как работать с Kafka в Node.js?

kafkajs — наиболее популярный Node.js клиент для Kafka. Producer: await producer.send({ topic: "events", messages: [{ key: userId, value: JSON.stringify(event) }] }). Consumer: await consumer.run({ eachMessage: async ({ topic, partition, message }) => { processEvent(JSON.parse(message.value.toString())) } }). Consumer groups для горизонтального масштабирования. Kafka гарантирует порядок внутри partition. Для Node.js Kafka особенно полезна для event streaming и audit log.