kafka

package
v0.1.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 28, 2023 License: Unlicense Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewKafka

func NewKafka(_c interface{}) (kafka.Kafka, error)

Types

type Kafka

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

func (*Kafka) Close

func (k *Kafka) Close() error

func (*Kafka) CommitMessages

func (k *Kafka) CommitMessages(ctx context.Context, m _kafka.Message) error

func (*Kafka) DialContext

func (k *Kafka) DialContext(ctx context.Context, network, addr string) (*_kafka.Conn, error)

func (*Kafka) FetchMessage

func (k *Kafka) FetchMessage(ctx context.Context) (_kafka.Message, error)

func (*Kafka) NewReader

func (k *Kafka) NewReader(t []string) *_kafka.Reader

func (*Kafka) ReadMessage

func (k *Kafka) ReadMessage(ctx context.Context) (_kafka.Message, error)

func (*Kafka) WriteMessages

func (k *Kafka) WriteMessages(ctx context.Context, m _kafka.Message) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL