kafkaconfluent

Documentation

Index

• Variables
• func MustNew(config Config) goduck.Stream
• func New(config Config) (goduck.Stream, error)
• type Config

Variables

var (
	//ErrEmptyBroker is returned when the the broker is missing from the Config struct
	ErrEmptyBroker = errors.New("bad config: empty broker")
	//ErrEmptyTopic is returned when the the Topic is missing from the Config struct
	ErrEmptyTopic = errors.New("bad config: empty topic")
	//ErrEmptyUsername is returned when the the Username is missing from the Config struct
	ErrEmptyUsername = errors.New("bad config: empty username")
	//ErrEmptyPassword is returned when the the Password is missing from the Config struct
	ErrEmptyPassword = errors.New("bad config: empty password")
)

Functions

func MustNew

func MustNew(config Config) goduck.Stream

MustNew creates a confluent-kafkam with default configs

func New

func New(config Config) (goduck.Stream, error)

New creates a confluent-kafka-go goduck.Stream with default configs

Types

type Config

type Config struct {
	Brokers  []string
	GroupID  string
	Username string
	Password string

	// RDKafkaConfig can specify librdkafka configs. If this is variable is set, the
	// other variables (Brokers, GroupID, Username and Password) are ignored
	RDKafkaConfig *kafka.ConfigMap

	Topics []string

	// PoolTimeout is the value passed to the internal consumer.Pool(...)
	// function. Default: 1s
	PoolTimeout time.Duration

	// DisableCommit indicates that offsets should never be commited, even
	// after calling Done()
	DisableCommit bool
}

Config contains the configuration necessary to build the confluent-kafka-go goduck.Stream