Methods:
createAdminClient()
Create a new AdminClient for making topics, partitions, and more. This is a factory method because it immediately starts an active handle with the brokers.
- Source:
createSerializer() → {function}
Create a serializer Method simply wraps a serializer provided by a user so it adds context to the error
Returns:
- Type
- function
RefCounter()
Ref counter class. Is used to basically determine active/inactive and allow callbacks that hook into each. For the producer, it is used to begin rapid polling after a produce until the delivery report is dispatched.
- Source:
Topic()
Create a topic. Just returns the string you gave it right now. Looks like a class, but all it does is return the topic name. This is so that one day if there are interface changes that allow different use of topic parameters, we can just add to this constructor and have it return something richer
- Source:
TopicPartition()
Create a topic partition. Just does some validation and decoration on topic partitions provided. Goal is still to behave like a plain javascript object but with validation and potentially some extra methods
- Source: