kafka

type CompressionStrategy string

type Config struct {
	ProducerConfig     `yaml:",inline"`
	Topic              string        `yaml:"topic"`
	TopicPattern       string        `yaml:"topicPattern"`
	MaxQueueSize       int           `yaml:"maxQueueSize" default:"51200"`
	BatchTimeout       time.Duration `yaml:"batchTimeout" default:"5s"`
	MaxExportBatchSize int           `yaml:"maxExportBatchSize" default:"2048"`
	Workers            int           `yaml:"workers" default:"5"`
}

type EncodingType string

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

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

type PartitionStrategy string

type ProducerConfig struct {
	Brokers         string           `yaml:"brokers"`
	TLS             bool             `yaml:"tls" default:"false"`
	TLSClientConfig *TLSClientConfig `yaml:"tlsClientConfig"`
	SASLConfig      *SASLConfig      `yaml:"sasl"`
	FlushFrequency  time.Duration    `yaml:"flushFrequency" default:"10s"`
	FlushBytes      int              `yaml:"flushBytes" default:"1000000"`
	// MaxMessageBytes is the maximum permitted size of a message produced
	// by this client. Must be set <= the broker's message.max.bytes. Default
	// 1000000 matches sarama's historical default; raise this when publishing
	// large payloads (e.g. blob-tx mempool events with sidecars).
	MaxMessageBytes int                 `yaml:"maxMessageBytes" default:"1000000"`
	MaxRetries      int                 `yaml:"maxRetries" default:"3"`
	Compression     CompressionStrategy `yaml:"compression" default:"none"`
	RequiredAcks    RequiredAcks        `yaml:"requiredAcks" default:"leader"`
	Partitioning    PartitionStrategy   `yaml:"partitioning" default:"none"`
	Encoding        EncodingType        `yaml:"encoding" default:"json"`
	Version         string              `yaml:"version"`
}

type RequiredAcks string

type SASLConfig struct {
	Mechanism    SASLMechanism `yaml:"mechanism" default:"PLAIN"`
	Version      int16         `yaml:"version" default:"1"`
	User         string        `yaml:"user"`
	Password     string        `yaml:"password"`
	PasswordFile string        `yaml:"passwordFile"`
}

type SASLMechanism string

type TLSClientConfig struct {
	CertificatePath string `yaml:"certificatePath"`
	KeyPath         string `yaml:"keyPath"`
	CACertificate   string `yaml:"caCertificate"`
}