CreateFakeKafkaConnect is the function to create kafkaconnect object for unit test only.

Kind takes an unqualified kind and returns back a Group qualified GroupKind.

Resource takes an unqualified resource and returns a Group qualified GroupResource.

DomainStyle will create ingress like kafkaconnectName.parentDomain.

PathStyle will create ingress like parentDomain/kafkaconnectName.

AddToScheme is a global function that registers this API group & version to a scheme.

SchemeBuilder is used to add go types to the GroupVersionKind scheme.

SchemeGroupVersion is group version used to register these objects.

IngressSpec defines how we need to create ingress to expose the kafka connect rest api.

KafkaConnect is the Schema for the kafkaconnects API +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true +kubebuilder:subresource:status +kubebuilder:resource:path=kafkaconnects,scope=Namespaced +genclient.

KafkaConnectAutoScaler is the Schema for the kafkaconnectautoscalers API +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true +kubebuilder:subresource:status +kubebuilder:resource:path=kafkaconnectautoscalers,scope=Namespaced +genclient.

KafkaConnectAutoScalerList contains a list of KafkaConnectAutoScaler +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object.

KafkaConnectAutoScalerSpec defines the desired state of KafkaConnectAutoScaler +k8s:openapi-gen=true.

KafkaConnectAutoScalerStatus defines the observed state of KafkaConnectAutoScaler +k8s:openapi-gen=true.

KafkaConnectList contains a list of KafkaConnect +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object.

KafkaConnectorConfig define one connector will be created if it's different from the existing one.

KafkaConnectorReference contains enough information to let you identify the referred kafka connector.

KafkaConnectorsSpec define the list of the connector config and the number of task per pod.

KafkaConnectorStatus defines the observed state of each KafkaConnector +k8s:openapi-gen=true.

KafkaConnectSpec defines the desired state of KafkaConnect this resource will create a Deployment and a Service by default if IngressSpec is given, then it will also create an ingress obj.

KafkaConnectStatus defines the observed state of KafkaConnect +k8s:openapi-gen=true.

IngressStyle define the style of the ingress created, either a subDomain or a path.