Node await repl kafka

Natarajan Santhosh

·

Follow

Aug 29, 2022

--

Listen

Share

npm install kafkajsnode --experimental-repl-await#inside repl>
const { Kafka } = require('kafkajs')const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ["ec.us-west-2.compute.amazonaws.com:9092"]
})const producer = kafka.producer()await producer.connect()await producer.send({
  topic: 'quickstart',
  messages: [
    { value: 'Hello KafkaJS user!' },
  ],
})