consumer

package

v0.0.0-...-ecf8d90 Latest Latest Go to latest Published: Apr 28, 2022 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation ¶

Index ¶

type Consumer
- func New(cfg *config.Config) Consumer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Consumer ¶

type Consumer interface {
	FetchMessage(ctx context.Context) (kafka.Message, error)
	Close() error
	CommitMessages(ctx context.Context, m kafka.Message) error
}

Consumer interface defines consumer methods.

func New ¶

func New(cfg *config.Config) Consumer

New configures Kafka consumer that consumes from configured topic.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
model

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