kafka

Documentation

Overview

THIS IS AN EXPERIMENTAL DRIVER, PLEASE USE WITH CAUTION

Index

• type Provider
  • func (p *Provider) Publish(ctx context.Context, topic string, m *pubsub.Msg) error
  • func (p *Provider) Shutdown()
  • func (p *Provider) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)

Types

type Provider

type Provider struct {
	Brokers  []string
	Balancer kafka.Balancer
	Reader   *kafka.Reader
	// contains filtered or unexported fields
}

Provider is a Kafka based pubsub provider

func (*Provider) Publish

func (p *Provider) Publish(ctx context.Context, topic string, m *pubsub.Msg) error

Publish publishes a message to Kafka with a uuid as the key

func (*Provider) Shutdown

func (p *Provider) Shutdown()

func (*Provider) Subscribe

func (p *Provider) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)

Subscribe implements Subscribe