kafka

Documentation

Index

• type Publisher
  • func (p *Publisher) SetKey(key string)
  • func (p *Publisher) Shutdown() error
  • func (p *Publisher) Startup() error
• type Subscriber
  • func (c *Subscriber) Consume(topic string, messages <-chan *message.Message)
  • func (s *Subscriber) Shutdown() error
  • func (s *Subscriber) Startup() error

Types

type Publisher

type Publisher struct {
	*kafka.Publisher
	PartitionKey kafka.GeneratePartitionKey
	Key          string
	Config       *config.Configuration `inject:"config"`
}

func (*Publisher) SetKey

func (p *Publisher) SetKey(key string)

func (*Publisher) Shutdown

func (p *Publisher) Shutdown() error

func (*Publisher) Startup

func (p *Publisher) Startup() error

type Subscriber

type Subscriber struct {
	*kafka.Subscriber
	Conf *config.Configuration `inject:"config"`
}

func (*Subscriber) Consume

func (c *Subscriber) Consume(topic string, messages <-chan *message.Message)

func (*Subscriber) Shutdown

func (s *Subscriber) Shutdown() error

func (*Subscriber) Startup

func (s *Subscriber) Startup() error