kafka

Documentation

Index

• func NewAsyncProducer(conf Config) (sarama.AsyncProducer, error)
• func NewConsumer(conf Config) (sarama.Consumer, error)
• func NewConsumerGroup(conf Config, group string) (sarama.ConsumerGroup, error)
• func NewSyncProducer(conf Config) (sarama.SyncProducer, error)
• type Config

Functions

func NewAsyncProducer

func NewAsyncProducer(conf Config) (sarama.AsyncProducer, error)

NewAsyncProducer new async producer

func NewConsumer

func NewConsumer(conf Config) (sarama.Consumer, error)

NewConsumer new kafka consumer

func NewConsumerGroup

func NewConsumerGroup(conf Config, group string) (sarama.ConsumerGroup, error)

NewConsumerGroup new kafka consumer group

func NewSyncProducer

func NewSyncProducer(conf Config) (sarama.SyncProducer, error)

NewSyncProducer new sync producer

Types

type Config

type Config struct {
	Sarama sarama.Config `yaml:"sarama"`

	Broker []string    `yaml:"broker"`
	TLS    *tls.Config `yaml:"tls"`
}

Config config