config

Documentation

Index

• type Connector
  • func (c *Connector) ApplyDefaults()
• type Kafka
  • func (k *Kafka) GetBalancer() kafka.Balancer
  • func (k *Kafka) GetCompression() int8
• type RejectionLog

Types

type Connector

type Connector struct {
	Kafka Kafka      `yaml:"kafka" mapstructure:"kafka"`
	Dcp   config.Dcp `yaml:",inline" mapstructure:",squash"`
}

func (*Connector) ApplyDefaults

func (c *Connector) ApplyDefaults()

type Kafka

type Kafka struct {
	ProducerBatchBytes          any               `yaml:"producerBatchBytes"`
	CollectionTopicMapping      map[string]string `yaml:"collectionTopicMapping"`
	InterCAPath                 string            `yaml:"interCAPath"`
	InterCA                     string            `yaml:"interCA"`
	ScramUsername               string            `yaml:"scramUsername"`
	ScramPassword               string            `yaml:"scramPassword"`
	RootCAPath                  string            `yaml:"rootCAPath"`
	RootCA                      string            `yaml:"rootCA"`
	ClientID                    string            `yaml:"clientID"`
	Balancer                    string            `yaml:"balancer"`
	Brokers                     []string          `yaml:"brokers"`
	MetadataTopics              []string          `yaml:"metadataTopics"`
	ProducerMaxAttempts         int               `yaml:"producerMaxAttempts"`
	ReadTimeout                 time.Duration     `yaml:"readTimeout"`
	WriteTimeout                time.Duration     `yaml:"writeTimeout"`
	RequiredAcks                int               `yaml:"requiredAcks"`
	ProducerBatchSize           int               `yaml:"producerBatchSize"`
	MetadataTTL                 time.Duration     `yaml:"metadataTTL"`
	ProducerBatchTickerDuration time.Duration     `yaml:"producerBatchTickerDuration"`
	Compression                 int8              `yaml:"compression"`
	SecureConnection            bool              `yaml:"secureConnection"`
	AllowAutoTopicCreation      bool              `yaml:"allowAutoTopicCreation"`
	RejectionLog                RejectionLog      `yaml:"rejectionLog"`
}

func (*Kafka) GetBalancer

func (k *Kafka) GetBalancer() kafka.Balancer

func (*Kafka) GetCompression

func (k *Kafka) GetCompression() int8

type RejectionLog

type RejectionLog struct {
	Topic        string `yaml:"topic"`
	IncludeValue bool   `yaml:"includeValue"`
}