config

Documentation

Index

• func ConnectProducer(brokersUrl []string) (sarama.SyncProducer, error)
• func GetKafkaConfig(username, password string) *sarama.Config
• func RetryKafkaConnection(brokers []string, maxRetries int, retryInterval time.Duration) (sarama.SyncProducer, error)
• func RetryKafkaConnectionMock(brokers []string, maxRetries int, retryInterval time.Duration, ...) (sarama.SyncProducer, error)
• type Config
  • func New(filenames ...string) Config

Functions

func ConnectProducer

func ConnectProducer(brokersUrl []string) (sarama.SyncProducer, error)

func GetKafkaConfig

func GetKafkaConfig(username, password string) *sarama.Config

func RetryKafkaConnection

func RetryKafkaConnection(brokers []string, maxRetries int, retryInterval time.Duration) (sarama.SyncProducer, error)

Retry logic for connecting to Kafka

func RetryKafkaConnectionMock

func RetryKafkaConnectionMock(brokers []string, maxRetries int, retryInterval time.Duration, dialFunc func([]string) (sarama.SyncProducer, error)) (sarama.SyncProducer, error)

Types

type Config

type Config interface {
	Get(key string) string
	Set(key, value string)
}

func New

func New(filenames ...string) Config