Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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"` ScramUsername string `yaml:"scramUsername"` ScramPassword string `yaml:"scramPassword"` RootCAPath string `yaml:"rootCAPath"` 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"` }
func (*Kafka) GetBalancer ¶ added in v1.1.31
func (k *Kafka) GetBalancer() kafka.Balancer
func (*Kafka) GetCompression ¶
Click to show internal directories.
Click to hide internal directories.