configuration

Documentation

Index

• Variables
• type KafkaConfiguration
  • func NewKafkaConfiguration(serverAddress string, user string, password string, clientId string, ...) *KafkaConfiguration
  • func NewKafkaConfigurationFromEnv() (*KafkaConfiguration, error)
  • func (configuration *KafkaConfiguration) GetConsumerConfig() (*kafka.ConfigMap, error)
  • func (configuration *KafkaConfiguration) GetProducerConfig() (*kafka.ConfigMap, error)

Variables

var (
	EnvValueMissingErr = errors.New("required configuration value is missing from env variables")
)

Types

type KafkaConfiguration

type KafkaConfiguration struct {
	// contains filtered or unexported fields
}

KafkaConfiguration holds data allowing for broker connection

func NewKafkaConfiguration

func NewKafkaConfiguration(serverAddress string, user string, password string, clientId string, consumerGroupId string) *KafkaConfiguration

NewKafkaConfiguration creates new KafkaConfiguration using supplied data

func NewKafkaConfigurationFromEnv

func NewKafkaConfigurationFromEnv() (*KafkaConfiguration, error)

NewKafkaConfigurationFromEnv loads all necessary data to create KafkaConfiguration from env variables

func (*KafkaConfiguration) GetConsumerConfig

func (configuration *KafkaConfiguration) GetConsumerConfig() (*kafka.ConfigMap, error)

func (*KafkaConfiguration) GetProducerConfig

func (configuration *KafkaConfiguration) GetProducerConfig() (*kafka.ConfigMap, error)