kafka

type ConsumerConfig struct {
	Retry             RetryConfig
	Fetch             FetchConfig
	MaxWaitTime       int64
	MaxProcessingTime int64
	Return            ReturnConfig
	Offsets           OffsetsConfig
}

type ConsumerKafkaConfig struct {
	ConsumerKafka     KafkaConfig
	Zookeeper         ZookeeperConfig
	Topics            []string
	ConsumerGroupName string
	// contains filtered or unexported fields
}

type FetchConfig struct {
	Min     int32
	Default int32
	Max     int32
}

type FlushConfig struct {
	MaxMessages int
}

type KafkaConfig struct {
	Name     string
	Addrs    []string `conf:"env"`
	Net      NetConfig
	MetaData MetaDataConfig
	Producer ProducerConfig
	Consumer ConsumerConfig
	Version  string
}

type MetaDataConfig struct {
	Retry            RetryConfig
	RefreshFrequency int64
}

type NetConfig struct {
	MaxOpenRequests int
	DialTimeout     int64
	ReadTimeout     int64
	WriteTimeout    int64
	KeepAlive       int64
	SASL            SASLConfig
}

type OffsetsConfig struct {
	CommitInterval int64
	Initial        int64
	Retention      int64
}

type ProducerConfig struct {
	MaxMessageBytes int
	RequiredAcks    int
	Timeout         int64
	Compression     int8
	Return          ReturnConfig
	Flush           FlushConfig
	Retry           RetryConfig
}

type ProducerKafkaConfig struct {
	ProducerKafka KafkaConfig
	// contains filtered or unexported fields
}

type RetryConfig struct {
	Max     int
	Backoff int64
}

type ReturnConfig struct {
	Successes bool
	Errors    bool
}

type SASLConfig struct {
	Enable    bool
	Handshake bool
	User      string
	Password  string
}

type ZookeeperConfig struct {
	Name    string
	Addrs   []string `conf:"env"`
	Timeout int64
	Chroot  string
}