kafka

Documentation

Index

• type Publisher
  • func NewPublisher(addr, topic string) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, key string, message interface{}) error

Types

type Publisher

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

Publisher is an implementation of the Publisher interface for Kafka.

func NewPublisher

func NewPublisher(addr, topic string) *Publisher

NewPublisher returns a new instance of Publisher for the given address and topic.

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, key string, message interface{}) error

Publish pushes a new message to Kafka, with the given key and a value as message as a JSON string.