Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func NewConsumer(conf *ConsumerConfig) (*Consumer, error)
func (*Consumer) Receive ¶
func (c *Consumer) Receive(callback MsgProcess)
type ConsumerConfig ¶
type MsgProcess ¶
type MsgProcess func(ctx context.Context, msg *sarama.ConsumerMessage) (err error)
type ProducerConfig ¶
type SyncProducer ¶
type SyncProducer struct {
// contains filtered or unexported fields
}
func NewSyncProducer ¶
func NewSyncProducer(config *ProducerConfig) (*SyncProducer, error)
func (*SyncProducer) Close ¶
func (sp *SyncProducer) Close()
Click to show internal directories.
Click to hide internal directories.