storage

Documentation

Index

• type KafkaProducer
  • func NewKafkaProducer(brokers []string, topic string) *KafkaProducer
  • func (kp *KafkaProducer) Close() error
  • func (kp *KafkaProducer) Produce(key, value []byte) error

Types

type KafkaProducer

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

func NewKafkaProducer

func NewKafkaProducer(brokers []string, topic string) *KafkaProducer

func (*KafkaProducer) Close

func (kp *KafkaProducer) Close() error

func (*KafkaProducer) Produce

func (kp *KafkaProducer) Produce(key, value []byte) error