Skip to content

Kafka Producer

The Kafka Producer is sending message records to a Topic destination to a Kafka messaging server.

Basic Usage

Send record to a given topic (implicitly create producer if needed):

import { producer } from "sdk/producer";
producer.topic("topic1", "{}").send("key1", "value1");

Close the producer:

import { producer } from "sdk/producer";


Function Description Returns
topic(destination, configuration) Returns an object representing a Kafka Topic Topic
close(configuration) Closes the Producer -

Configuration object key-value pairs can be taken from



Function Description Returns
send(key, value) Send a message record by a key and value to a Kafka Topic -