kafkaconnectuserconfig

Documentation

Index

• type KafkaConnect
  • func (in *KafkaConnect) DeepCopy() *KafkaConnect
  • func (in *KafkaConnect) DeepCopyInto(out *KafkaConnect)
• type KafkaConnectUserConfig
  • func (in *KafkaConnectUserConfig) DeepCopy() *KafkaConnectUserConfig
  • func (in *KafkaConnectUserConfig) DeepCopyInto(out *KafkaConnectUserConfig)

Types

type KafkaConnect

type KafkaConnect struct {
	// +kubebuilder:validation:MaxLength=249
	// The name of the topic where connector and task configuration data are stored.This must be the same for all workers with the same group_id.
	ConfigStorageTopic *string `groups:"create,update" json:"config_storage_topic,omitempty"`

	// +kubebuilder:validation:MaxLength=249
	// A unique string that identifies the Connect cluster group this worker belongs to.
	GroupId *string `groups:"create,update" json:"group_id,omitempty"`

	// +kubebuilder:validation:MaxLength=249
	// The name of the topic where connector and task configuration offsets are stored.This must be the same for all workers with the same group_id.
	OffsetStorageTopic *string `groups:"create,update" json:"offset_storage_topic,omitempty"`

	// +kubebuilder:validation:MaxLength=249
	// The name of the topic where connector and task configuration status updates are stored.This must be the same for all workers with the same group_id.
	StatusStorageTopic *string `groups:"create,update" json:"status_storage_topic,omitempty"`
}

Kafka Connect service configuration values

func (*KafkaConnect) DeepCopy

func (in *KafkaConnect) DeepCopy() *KafkaConnect

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

func (*KafkaConnect) DeepCopyInto

func (in *KafkaConnect) DeepCopyInto(out *KafkaConnect)

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

type KafkaConnectUserConfig

type KafkaConnectUserConfig struct {
	// Kafka Connect service configuration values
	KafkaConnect *KafkaConnect `groups:"create,update" json:"kafka_connect,omitempty"`
}

Integration user config

func (*KafkaConnectUserConfig) DeepCopy

func (in *KafkaConnectUserConfig) DeepCopy() *KafkaConnectUserConfig

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

func (*KafkaConnectUserConfig) DeepCopyInto

func (in *KafkaConnectUserConfig) DeepCopyInto(out *KafkaConnectUserConfig)

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