config

Documentation

Index

• type Config
  • func LoadConfig() *Config
  • func (c *Config) GetTimeZone() *time.Location
  • func (c *Config) KafkaVersion() sarama.KafkaVersion

Types

type Config

type Config struct {
	KafkaBrokers       []string `required:"true"`
	Topics             []string `required:"true"` // (example: '{"Topic1", "Topic2"}'
	OutputDir          string   `default:"OUTPUT_DATA"`
	KafkaClientID      string   `default:"kafka-dumper"`
	KafkaGroupID       string   `default:"kafka-dumper"`
	KafkaVersionString string   `default:"0.10.2.0"`
	Timezone           string   `default:"GMT"`
	Log                string   `default:"Info"`
	LocalLog           bool     `required:"false"` // if true  - will write log to stdout and to

	Overwrite bool `required:"false"` // if true - will create unique consumerID and messages will be received again
	Newest    bool `required:"false"` // if set true - will start dump all messages that appears in

	Init bool `required:"false"`
	// contains filtered or unexported fields
}

Config stores service config parameters

func LoadConfig

func LoadConfig() *Config

LoadConfig loads configuration for service to struct Config and store topics to Topics map

func (*Config) GetTimeZone

func (c *Config) GetTimeZone() *time.Location

GetTimeZone - parses timezone string and return time.Location representation

func (*Config) KafkaVersion

func (c *Config) KafkaVersion() sarama.KafkaVersion

KafkaVersion getter