producer

Documentation

Index

• type FinderKafkaProducer
  • func NewFinderKafkaProducer(brokers []string) (*FinderKafkaProducer, error)
  • func (this *FinderKafkaProducer) OnProduce(topic string, data interface{}, onMessageCallback OnMessageCallback)
• type FinderKafkaSyncProducer
  • func NewFinderKafkaSyncProducer(brokers []string) (*FinderKafkaSyncProducer, error)
  • func (this *FinderKafkaSyncProducer) OnProduce(topic string, data interface{}) (partition int32, offset int64, err error)
• type OnMessageCallback

Types

type FinderKafkaProducer

type FinderKafkaProducer struct {
	Producer sarama.AsyncProducer
	// contains filtered or unexported fields
}

async producer

func NewFinderKafkaProducer

func NewFinderKafkaProducer(brokers []string) (*FinderKafkaProducer, error)

func (*FinderKafkaProducer) OnProduce

func (this *FinderKafkaProducer) OnProduce(topic string, data interface{}, onMessageCallback OnMessageCallback)

生产

type FinderKafkaSyncProducer

type FinderKafkaSyncProducer struct {
	Producer sarama.SyncProducer
	// contains filtered or unexported fields
}

func NewFinderKafkaSyncProducer

func NewFinderKafkaSyncProducer(brokers []string) (*FinderKafkaSyncProducer, error)

func (*FinderKafkaSyncProducer) OnProduce

func (this *FinderKafkaSyncProducer) OnProduce(topic string, data interface{}) (partition int32, offset int64, err error)

发送同步消息

type OnMessageCallback

type OnMessageCallback func(sarama.AsyncProducer)