Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKafkaReader ¶
func NewKafkaReader(config config.KafkaConsumerConfig) *kafkaReader
NewKafkaReader is sa constructor function for the kafkaReader type
func NewKafkaWriter ¶
func NewKafkaWriter(config config.KafkaProducerConfig) *kafkaWriter
NewKafkaWriter is sa constructor function for the kafkaWriter type
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.