kafkamirrormakeruserconfig

Documentation

Index

• type KafkaMirrormaker
  • func (in *KafkaMirrormaker) DeepCopy() *KafkaMirrormaker
  • func (in *KafkaMirrormaker) DeepCopyInto(out *KafkaMirrormaker)
• type KafkaMirrormakerUserConfig
  • func (in *KafkaMirrormakerUserConfig) DeepCopy() *KafkaMirrormakerUserConfig
  • func (in *KafkaMirrormakerUserConfig) DeepCopyInto(out *KafkaMirrormakerUserConfig)

Types

type KafkaMirrormaker

type KafkaMirrormaker struct {
	// +kubebuilder:validation:Enum="earliest";"latest"
	// Set where consumer starts to consume data. Value `earliest`: Start replication from the earliest offset. Value `latest`: Start replication from the latest offset. Default is `earliest`.
	ConsumerAutoOffsetReset *string `groups:"create,update" json:"consumer_auto_offset_reset,omitempty"`

	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=5242880
	// The minimum amount of data the server should return for a fetch request
	ConsumerFetchMinBytes *int `groups:"create,update" json:"consumer_fetch_min_bytes,omitempty"`

	// +kubebuilder:validation:Minimum=100
	// +kubebuilder:validation:Maximum=20000
	// Set consumer max.poll.records. The default is 500.
	ConsumerMaxPollRecords *int `groups:"create,update" json:"consumer_max_poll_records,omitempty"`

	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Maximum=5242880
	// The batch size in bytes producer will attempt to collect before publishing to broker.
	ProducerBatchSize *int `groups:"create,update" json:"producer_batch_size,omitempty"`

	// +kubebuilder:validation:Minimum=5242880
	// +kubebuilder:validation:Maximum=134217728
	// The amount of bytes producer can use for buffering data before publishing to broker.
	ProducerBufferMemory *int `groups:"create,update" json:"producer_buffer_memory,omitempty"`

	// +kubebuilder:validation:Enum="gzip";"lz4";"none";"snappy";"zstd"
	// Specify the default compression type for producers. This configuration accepts the standard compression codecs ('gzip', 'snappy', 'lz4', 'zstd'). It additionally accepts 'none' which is the default and equivalent to no compression.
	ProducerCompressionType *string `groups:"create,update" json:"producer_compression_type,omitempty"`

	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Maximum=5000
	// The linger time (ms) for waiting new data to arrive for publishing.
	ProducerLingerMs *int `groups:"create,update" json:"producer_linger_ms,omitempty"`

	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Maximum=268435456
	// The maximum request size in bytes.
	ProducerMaxRequestSize *int `groups:"create,update" json:"producer_max_request_size,omitempty"`
}

Kafka MirrorMaker configuration values

func (*KafkaMirrormaker) DeepCopy

func (in *KafkaMirrormaker) DeepCopy() *KafkaMirrormaker

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaMirrormaker.

func (*KafkaMirrormaker) DeepCopyInto

func (in *KafkaMirrormaker) DeepCopyInto(out *KafkaMirrormaker)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaMirrormakerUserConfig

type KafkaMirrormakerUserConfig struct {
	// +kubebuilder:validation:MaxLength=128
	// +kubebuilder:validation:Pattern=`^[a-zA-Z0-9_.-]+$`
	// The alias under which the Kafka cluster is known to MirrorMaker. Can contain the following symbols: ASCII alphanumerics, '.', '_', and '-'.
	ClusterAlias *string `groups:"create,update" json:"cluster_alias,omitempty"`

	// Kafka MirrorMaker configuration values
	KafkaMirrormaker *KafkaMirrormaker `groups:"create,update" json:"kafka_mirrormaker,omitempty"`
}

Integration user config

func (*KafkaMirrormakerUserConfig) DeepCopy

func (in *KafkaMirrormakerUserConfig) DeepCopy() *KafkaMirrormakerUserConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaMirrormakerUserConfig.

func (*KafkaMirrormakerUserConfig) DeepCopyInto

func (in *KafkaMirrormakerUserConfig) DeepCopyInto(out *KafkaMirrormakerUserConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.