Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct { sarama.Consumer Conf ConsumerConfig }
type ConsumerConfig ¶
type ConsumerConfig Config
func (*ConsumerConfig) Init ¶
func (c *ConsumerConfig) Init()
func (*ConsumerConfig) InitBeforeInject ¶
func (c *ConsumerConfig) InitBeforeInject()
type Producer ¶
type Producer struct { sarama.SyncProducer Conf ProducerConfig }
type ProducerConfig ¶
type ProducerConfig Config
func (*ProducerConfig) Build ¶
func (c *ProducerConfig) Build() (sarama.SyncProducer, error)
func (*ProducerConfig) Init ¶
func (c *ProducerConfig) Init()
func (*ProducerConfig) InitBeforeInject ¶
func (c *ProducerConfig) InitBeforeInject()
Click to show internal directories.
Click to hide internal directories.