kafka

package

v1.7.0-rc.4 Latest Latest Go to latest Published: Apr 5, 2022 License: Apache-2.0 Imports: 13 Imported by: 2

Details

This section is empty.

This section is empty.

This section is empty.

type Kafka struct {
	Version sarama.KafkaVersion
	// 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) Close() error

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) ([]byte, error)) error