consumer

package
v1.15.1 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Builder

type Builder interface {
	NewConsumer() (Consumer, error)
}

Builder builds a new kafka consumer

type Configuration

type Configuration struct {
	auth.AuthenticationConfig
	Consumer

	Brokers         []string
	Topic           string
	GroupID         string
	ClientID        string
	ProtocolVersion string
}

Configuration describes the configuration properties needed to create a Kafka consumer

func (*Configuration) NewConsumer

func (c *Configuration) NewConsumer() (Consumer, error)

NewConsumer creates a new kafka consumer

type Consumer

type Consumer interface {
	Partitions() <-chan cluster.PartitionConsumer
	MarkPartitionOffset(topic string, partition int32, offset int64, metadata string)
	io.Closer
}

Consumer is an interface to features of Sarama that are necessary for the consumer

Jump to

Keyboard shortcuts

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