kafka

Documentation

Index

• Variables
• func InitTopic(bootstrapUrl string, topics ...string) (err error)
• func NewConsumer(ctx context.Context, config config.Config, topic string, ...) error
• func NewProducer(ctx context.Context, config config.Config, topic string) (interfaces.Producer, error)
• type FactoryType
  • func (FactoryType) NewConsumer(ctx context.Context, config config.Config, topic string, ...) error
  • func (FactoryType) NewProducer(ctx context.Context, config config.Config, topic string) (interfaces.Producer, error)
• type Producer
  • func (this *Producer) Produce(key string, message []byte) error

Variables

var Factory = FactoryType{}

Functions

func InitTopic

func InitTopic(bootstrapUrl string, topics ...string) (err error)

func NewConsumer

func NewConsumer(ctx context.Context, config config.Config, topic string, listener func(delivery []byte) error) error

func NewProducer

func NewProducer(ctx context.Context, config config.Config, topic string) (interfaces.Producer, error)

Types

type FactoryType

type FactoryType struct{}

func (FactoryType) NewConsumer

func (FactoryType) NewConsumer(ctx context.Context, config config.Config, topic string, listener func(delivery []byte) error) error

func (FactoryType) NewProducer

func (FactoryType) NewProducer(ctx context.Context, config config.Config, topic string) (interfaces.Producer, error)

type Producer

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

func (*Producer) Produce

func (this *Producer) Produce(key string, message []byte) error