kafka

Documentation

Index

• type Kafka
  • func NewKafka() *Kafka
  • func (k *Kafka) Init(metadata bindings.Metadata) error
  • func (k *Kafka) Read(handler func(*bindings.ReadResponse) error) error
  • func (k *Kafka) Write(req *bindings.WriteRequest) error

Types

type Kafka

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

Kafka allows reading/writing to a Kafka consumer group

func NewKafka

func NewKafka() *Kafka

NewKafka returns a new kafka binding instance

func (*Kafka) Init

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

Init does metadata parsing and connection establishment

func (*Kafka) Read

func (k *Kafka) Read(handler func(*bindings.ReadResponse) error) error

func (*Kafka) Write

func (k *Kafka) Write(req *bindings.WriteRequest) error