@@ -161,10 +161,10 @@ type SourceConnectorSpec struct {
161161 // Archive points to a nar archive containing the connector. It can reference built-in connectors using the
162162 // builtin:// scheme.
163163 // +kubebuilder:validation:Optional
164- Archive string `json:"archive ,omitempty"`
164+ SourceType string `json:"sourceType ,omitempty"` // refer to `--source-type` as builtin connector
165165 // Builtin holds the resolved name of a built-in source connector.
166166 // +kubebuilder:validation:Optional
167- Builtin string `json:"builtin ,omitempty"`
167+ BatchSourceConfig * BatchSourceConfig `json:"batchSourceConfig ,omitempty"`
168168 // ClassName is the fully qualified source implementation class.
169169 // +kubebuilder:validation:Optional
170170 ClassName string `json:"className,omitempty"`
@@ -179,13 +179,6 @@ type SourceConnectorSpec struct {
179179
180180// SinkConnectorSpec describes configurable fields when a function overrides its sink implementation.
181181type SinkConnectorSpec struct {
182- // Archive points to a nar archive containing the connector. It can reference built-in connectors using the
183- // builtin:// scheme.
184- // +kubebuilder:validation:Optional
185- Archive string `json:"archive,omitempty"`
186- // Builtin holds the resolved name of a built-in sink connector.
187- // +kubebuilder:validation:Optional
188- Builtin string `json:"builtin,omitempty"`
189182 // SinkType refers to the built-in sink identifier when using connectors packaged with Pulsar.
190183 // +kubebuilder:validation:Optional
191184 SinkType string `json:"sinkType,omitempty"`
0 commit comments