kafkasegmentio

Documentation

Index

• func NewKafkaStream(config KafkaConfigs) goduck.Stream
• func NewKafkaStreamWithCustomConfigs(config kafka.ReaderConfig) goduck.Stream
• type KafkaConfigs

Functions

func NewKafkaStream

func NewKafkaStream(config KafkaConfigs) goduck.Stream

func NewKafkaStreamWithCustomConfigs

func NewKafkaStreamWithCustomConfigs(config kafka.ReaderConfig) goduck.Stream

NewKafkaStreamWithCustomConfigs allows creating a kafka connection with all configs from the SegmentIO library

Types

type KafkaConfigs

type KafkaConfigs struct {
	Brokers  []string
	Topic    string
	GroupID  string
	Username string
	Password string

	CommitInterval time.Duration
}

KafkaConfigs contains the configs for kafka connection