File tree Expand file tree Collapse file tree 5 files changed +272
-252
lines changed
Expand file tree Collapse file tree 5 files changed +272
-252
lines changed Original file line number Diff line number Diff line change 6161 go :
6262 type : string
6363 type : object
64+ input :
65+ properties :
66+ customSchemaSources :
67+ additionalProperties :
68+ type : string
69+ type : object
70+ customSerdeSources :
71+ additionalProperties :
72+ type : string
73+ type : object
74+ sourceSpecs :
75+ additionalProperties :
76+ properties :
77+ consumerProperties :
78+ additionalProperties :
79+ type : string
80+ type : object
81+ isRegexPattern :
82+ type : boolean
83+ receiverQueueSize :
84+ format : int32
85+ type : integer
86+ schemaProperties :
87+ additionalProperties :
88+ type : string
89+ type : object
90+ schemaType :
91+ type : string
92+ serdeClassname :
93+ type : string
94+ type : object
95+ type : object
96+ topicPattern :
97+ type : string
98+ topics :
99+ items :
100+ type : string
101+ type : array
102+ type : object
64103 java :
65104 properties :
66105 jar :
@@ -84,6 +123,30 @@ spec:
84123 cluster Important: Run "make" to regenerate code after modifying
85124 this file'
86125 type : string
126+ output :
127+ properties :
128+ customSchemaSinks :
129+ additionalProperties :
130+ type : string
131+ type : object
132+ producerConf :
133+ properties :
134+ maxPendingMessages :
135+ format : int32
136+ type : integer
137+ maxPendingMessagesAcrossPartitions :
138+ format : int32
139+ type : integer
140+ useThreadLocalProducers :
141+ type : boolean
142+ type : object
143+ sinkSchemaType :
144+ type : string
145+ sinkSerdeClassName :
146+ type : string
147+ topic :
148+ type : string
149+ type : object
87150 processingGuarantee :
88151 type : string
89152 pulsar :
@@ -128,35 +191,41 @@ spec:
128191 type : string
129192 type : object
130193 type : object
131- sink :
132- properties :
133- customSchemaSinks :
134- additionalProperties :
135- type : string
136- type : object
137- producerConf :
138- properties :
139- maxPendingMessages :
140- format : int32
141- type : integer
142- maxPendingMessagesAcrossPartitions :
143- format : int32
144- type : integer
145- useThreadLocalProducers :
146- type : boolean
147- type : object
148- sinkSchemaType :
149- type : string
150- sinkSerdeClassName :
151- type : string
152- topic :
153- type : string
154- type : object
155194 sinkType :
156195 type : string
157196 sourceType :
158197 type : string
159- sources :
198+ subscriptionName :
199+ type : string
200+ subscriptionPosition :
201+ type : string
202+ tenant :
203+ type : string
204+ timeout :
205+ format : int32
206+ type : integer
207+ type : object
208+ type : array
209+ sinks :
210+ items :
211+ description : SinkSpec defines the desired state of Topic
212+ properties :
213+ autoAck :
214+ type : boolean
215+ className :
216+ type : string
217+ cleanupSubscription :
218+ type : boolean
219+ clusterName :
220+ type : string
221+ deadLetterTopic :
222+ type : string
223+ golang :
224+ properties :
225+ go :
226+ type : string
227+ type : object
228+ input :
160229 properties :
161230 customSchemaSources :
162231 additionalProperties :
@@ -195,36 +264,6 @@ spec:
195264 type : string
196265 type : array
197266 type : object
198- subscriptionName :
199- type : string
200- subscriptionPosition :
201- type : string
202- tenant :
203- type : string
204- timeout :
205- format : int32
206- type : integer
207- type : object
208- type : array
209- sinks :
210- items :
211- description : SinkSpec defines the desired state of Topic
212- properties :
213- autoAck :
214- type : boolean
215- className :
216- type : string
217- cleanupSubscription :
218- type : boolean
219- clusterName :
220- type : string
221- deadLetterTopic :
222- type : string
223- golang :
224- properties :
225- go :
226- type : string
227- type : object
228267 java :
229268 properties :
230269 jar :
@@ -296,45 +335,6 @@ spec:
296335 type : string
297336 sourceType :
298337 type : string
299- sources :
300- properties :
301- customSchemaSources :
302- additionalProperties :
303- type : string
304- type : object
305- customSerdeSources :
306- additionalProperties :
307- type : string
308- type : object
309- sourceSpecs :
310- additionalProperties :
311- properties :
312- consumerProperties :
313- additionalProperties :
314- type : string
315- type : object
316- isRegexPattern :
317- type : boolean
318- receiverQueueSize :
319- format : int32
320- type : integer
321- schemaProperties :
322- additionalProperties :
323- type : string
324- type : object
325- schemaType :
326- type : string
327- serdeClassname :
328- type : string
329- type : object
330- type : object
331- topicPattern :
332- type : string
333- topics :
334- items :
335- type : string
336- type : array
337- type : object
338338 subscriptionName :
339339 type : string
340340 subscriptionPosition :
@@ -374,6 +374,30 @@ spec:
374374 cluster Important: Run "make" to regenerate code after modifying
375375 this file'
376376 type : string
377+ output :
378+ properties :
379+ customSchemaSinks :
380+ additionalProperties :
381+ type : string
382+ type : object
383+ producerConf :
384+ properties :
385+ maxPendingMessages :
386+ format : int32
387+ type : integer
388+ maxPendingMessagesAcrossPartitions :
389+ format : int32
390+ type : integer
391+ useThreadLocalProducers :
392+ type : boolean
393+ type : object
394+ sinkSchemaType :
395+ type : string
396+ sinkSerdeClassName :
397+ type : string
398+ topic :
399+ type : string
400+ type : object
377401 processingGuarantee :
378402 type : string
379403 pulsar :
@@ -414,30 +438,6 @@ spec:
414438 type : string
415439 type : object
416440 type : object
417- sink :
418- properties :
419- customSchemaSinks :
420- additionalProperties :
421- type : string
422- type : object
423- producerConf :
424- properties :
425- maxPendingMessages :
426- format : int32
427- type : integer
428- maxPendingMessagesAcrossPartitions :
429- format : int32
430- type : integer
431- useThreadLocalProducers :
432- type : boolean
433- type : object
434- sinkSchemaType :
435- type : string
436- sinkSerdeClassName :
437- type : string
438- topic :
439- type : string
440- type : object
441441 sinkType :
442442 type : string
443443 sourceConfig :
You can’t perform that action at this time.
0 commit comments