Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
Producer abstracts hub-of-hubs-kafka-transport kafka-producer's generic usage.
func NewProducer ¶
func NewProducer(compressor compressors.Compressor, log logr.Logger) (*Producer, error)
NewProducer returns a new instance of Producer object.
func (*Producer) GetVersion ¶
GetVersion returns an empty string if the object doesn't exist or an error occurred.
Click to show internal directories.
Click to hide internal directories.