Private
constructorPrivate constructor
This method is not intended to be used directly. This is a helper
method used by the Fluvio
class to pass in a native object,
along with top-level Fluvio client options, if any.
The native node module created by await (new Fluvio().connect()).topicProducer()
Private
innerSends a key-value event to this producer's topic
The Key data of the record to send
The Value data of the record to send
Sends a key-value event to this producer's topic
The Key data of the record to send
The Value data of the record to send
Sends an event to a specific partition within this producer's topic
The partition that this record will be sent to
Sends an event to a specific partition within this producer's topic
Buffered data to send to the Fluvio partition
The partition that this record will be sent to
Static
createFactory method for creating a new topic Producer; This method is used by the
Fluvio
class. It is not meant to be called directly;
The native node module created by await (new Fluvio().connect()).topicProducer()
Generated using TypeDoc
Topic Producer
Overview
An interface for producing events to a particular topic
A TopicProducer allows you to send events to the specific topic it was initialized for. Once you have a TopicProducer, you can send events to the topic, choosing which partition each event should be delivered to.
Example Construction
Do not construct this manually, instead use the following method:
This class constructor is used internally by the Fluvio client to provision a topic producer.
The
inner
object is a private object that is the native module created by the top-level Fluvio client.This class is not intended to be constructed manually.