package
0.2.9
Repository: https://github.com/ionos-cloud/streams.git
Documentation: pkg.go.dev

# Packages

Package mock is a generated GoMock package.

# Functions

DefaultConfig returns the default configuration for a Kafka reader.
NewReader creates a new Kafka reader.
WithBrokers configures the brokers for the reader.
WithDialer defines a dialer for the reader.
WithErrorLogger configures the error logger for the reader.
WithGroupID defines the consumer group ID.
WithLogger configures the logger for the reader.
WithTopic defines the topic for the reader.

# Interfaces

Reader ...

# Type aliases

Opt defines an option for a Kafka reader.