kafka

Documentation

Index

• func NewKafka(l logger.Logger) pubsub.PubSub
• type Kafka
  • func (k *Kafka) Close() error
  • func (k *Kafka) Features() []pubsub.Feature
  • func (k *Kafka) Init(metadata pubsub.Metadata) error
  • func (k *Kafka) Publish(req *pubsub.PublishRequest) error
  • func (k *Kafka) Subscribe(req pubsub.SubscribeRequest, handler func(msg *pubsub.NewMessage) error) error

Functions

func NewKafka

func NewKafka(l logger.Logger) pubsub.PubSub

NewKafka returns a new kafka pubsub instance

Types

type Kafka

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

Kafka allows reading/writing to a Kafka consumer group

func (*Kafka) Close

func (k *Kafka) Close() error

func (*Kafka) Features

func (k *Kafka) Features() []pubsub.Feature

func (*Kafka) Init

func (k *Kafka) Init(metadata pubsub.Metadata) error

Init does metadata parsing and connection establishment

func (*Kafka) Publish

func (k *Kafka) Publish(req *pubsub.PublishRequest) error

Publish message to Kafka cluster

func (*Kafka) Subscribe

func (k *Kafka) Subscribe(req pubsub.SubscribeRequest, handler func(msg *pubsub.NewMessage) error) error

Subscribe to topic in the Kafka cluster This call cannot block like its sibling in bindings/kafka because of where this is invoked in runtime.go