Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncProducer ¶
func NewAsyncProducer ¶
func NewAsyncProducer(opts *ProducerOptions, config *sarama.Config) (AsyncProducer, error)
type Consumer ¶
func NewConsumer ¶
func NewConsumer(opts *ConsumerOptions, config *sarama.Config) (Consumer, error)
type ConsumerOptions ¶
type ProducerOptions ¶
Click to show internal directories.
Click to hide internal directories.