Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetConsumerGroupConfig ¶
Types ¶
type Callback ¶
type Callback func(message *sarama.ConsumerMessage)
type ConsumerGroup ¶
type ConsumerGroup struct {
// contains filtered or unexported fields
}
func NewConsumerGroup ¶
func NewConsumerGroup(conf *ConsumerGroupConf, fn Callback) (*ConsumerGroup, error)
func (*ConsumerGroup) Close ¶
func (c *ConsumerGroup) Close()
type ConsumerGroupConf ¶
type ProducerConf ¶
type SyncProducer ¶
type SyncProducer struct {
// contains filtered or unexported fields
}
func NewSyncProducer ¶
func NewSyncProducer(conf *ProducerConf) (SyncProducer, error)
func (*SyncProducer) Close ¶
func (p *SyncProducer) Close()
func (*SyncProducer) SendByteMessage ¶
func (p *SyncProducer) SendByteMessage(topic string, value []byte) error
func (*SyncProducer) SendProducerMessage ¶
func (p *SyncProducer) SendProducerMessage(msg *sarama.ProducerMessage) error
func (*SyncProducer) SendStringMessage ¶
func (p *SyncProducer) SendStringMessage(topic, value string) error
Click to show internal directories.
Click to hide internal directories.