kafka

package

v1.0.2 Latest Latest Go to latest Published: Mar 3, 2021 License: MIT Imports: 13 Imported by: 2

Details

This section is empty.

This section is empty.

This section is empty.

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

Kafka allows reading/writing to a Kafka consumer group

func NewKafka(logger logger.Logger) *Kafka

NewKafka returns a new kafka binding instance

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

Init does metadata parsing and connection establishment

func (k *Kafka) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (k *Kafka) Operations() []bindings.OperationKind

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