生产者:
const { Kafka, Partitioners } = require("kafkajs"); (async () => { const kafka = new Kafka({ clientId: "test-app", brokers: ['1.14.217.220:9094'], }); const producer = kafka.producer({
京公网安备 11010502049817号