publisher

Documentation

Index

• type KafkaPublisher
  • func NewKafkaPublisher(client sarama.Client) *KafkaPublisher
  • func (p *KafkaPublisher) PublishMessage(ctx context.Context, topic, key string, data interface{}) (err error)

Types

type KafkaPublisher

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

KafkaPublisher kafka

func NewKafkaPublisher

func NewKafkaPublisher(client sarama.Client) *KafkaPublisher

NewKafkaPublisher constructor

func (*KafkaPublisher) PublishMessage

func (p *KafkaPublisher) PublishMessage(ctx context.Context, topic, key string, data interface{}) (err error)

PublishMessage method