kafka_producer

Documentation

Index

• type KafkaProducer
  • func New(addressList string) *KafkaProducer
  • func (kp *KafkaProducer) Close() error
  • func (kp *KafkaProducer) Init() error
  • func (kp *KafkaProducer) SendMessage(content, topic string, partitionKey ...string) (partition int32, offset int64, err error)

Types

type KafkaProducer

type KafkaProducer struct {
	// contains filtered or unexported fields
}

func New

func New(addressList string) *KafkaProducer

func (*KafkaProducer) Close

func (kp *KafkaProducer) Close() error

func (*KafkaProducer) Init

func (kp *KafkaProducer) Init() error

func (*KafkaProducer) SendMessage

func (kp *KafkaProducer) SendMessage(content, topic string, partitionKey ...string) (partition int32, offset int64, err error)

SendMessage 生产消息