Skip to content

Commit 7917365

Browse files
boolivarboolivar
committed
feat: kinesis-outbound-channel-adapter xsd schema
1 parent 92e94ac commit 7917365

File tree

1 file changed

+114
-0
lines changed

1 file changed

+114
-0
lines changed

‎int-aws/src/main/resources/org/springframework/schema/integration/aws/spring-integration-aws.xsd‎

Lines changed: 114 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -334,6 +334,120 @@
334334
</xsd:complexType>
335335
</xsd:element>
336336

337+
<xsd:element name="kinesis-outbound-channel-adapter">
338+
<xsd:annotation>
339+
<xsd:documentation><![CDATA[
340+
Defines an outbound 'KinesisMessageHandler' adapter
341+
for sending data to Amazon Kinesis streams.
342+
]]></xsd:documentation>
343+
</xsd:annotation>
344+
<xsd:complexType>
345+
<xsd:complexContent>
346+
<xsd:extension base="outboundChannelAdapter">
347+
<xsd:attributeGroup ref="integration:channelAdapterAttributes"/>
348+
<xsd:attribute name="kinesis-client" type="xsd:string" use="required">
349+
<xsd:annotation>
350+
<xsd:documentation><![CDATA[
351+
The 'software.amazon.awssdk.services.kinesis.KinesisAsyncClient' bean reference.
352+
]]></xsd:documentation>
353+
<xsd:appinfo>
354+
<tool:annotation kind="ref">
355+
<tool:expected-type type="software.amazon.awssdk.services.kinesis.KinesisAsyncClient"/>
356+
</tool:annotation>
357+
</xsd:appinfo>
358+
</xsd:annotation>
359+
</xsd:attribute>
360+
<xsd:attribute name="stream" type="xsd:string">
361+
<xsd:annotation>
362+
<xsd:documentation><![CDATA[
363+
The name of the stream to put the data record into.
364+
Mutually exclusive with 'stream-expression'.
365+
]]></xsd:documentation>
366+
</xsd:annotation>
367+
</xsd:attribute>
368+
<xsd:attribute name="stream-expression" type="xsd:string">
369+
<xsd:annotation>
370+
<xsd:documentation><![CDATA[
371+
The name of the stream to put the data record into.
372+
Mutually exclusive with 'stream'.
373+
]]></xsd:documentation>
374+
</xsd:annotation>
375+
</xsd:attribute>
376+
<xsd:attribute name="partition-key" type="xsd:string">
377+
<xsd:annotation>
378+
<xsd:documentation><![CDATA[
379+
Determines which shard in the stream the data record is assigned to.
380+
Mutually exclusive with 'partition-key-expression'.
381+
]]></xsd:documentation>
382+
</xsd:annotation>
383+
</xsd:attribute>
384+
<xsd:attribute name="partition-key-expression" type="xsd:string">
385+
<xsd:annotation>
386+
<xsd:documentation><![CDATA[
387+
Determines which shard in the stream the data record is assigned to.
388+
Mutually exclusive with 'partition-key'.
389+
]]></xsd:documentation>
390+
</xsd:annotation>
391+
</xsd:attribute>
392+
<xsd:attribute name="explicit-hash-key" type="xsd:string">
393+
<xsd:annotation>
394+
<xsd:documentation><![CDATA[
395+
The hash value used to explicitly determine the shard
396+
the data record is assigned to by overriding the partition key hash.
397+
Mutually exclusive with 'explicit-hash-key-expression'.
398+
]]></xsd:documentation>
399+
</xsd:annotation>
400+
</xsd:attribute>
401+
<xsd:attribute name="explicit-hash-key-expression" type="xsd:string">
402+
<xsd:annotation>
403+
<xsd:documentation><![CDATA[
404+
The hash value used to explicitly determine the shard
405+
the data record is assigned to by overriding the partition key hash.
406+
Mutually exclusive with 'explicit-hash-key'.
407+
]]></xsd:documentation>
408+
</xsd:annotation>
409+
</xsd:attribute>
410+
<xsd:attribute name="sequence-number-expression" type="xsd:string">
411+
<xsd:annotation>
412+
<xsd:documentation><![CDATA[
413+
Guarantees strictly increasing sequence numbers,
414+
for puts from the same client and to the same partition key.
415+
If this parameter is not set, records
416+
are coarsely ordered based on arrival time.
417+
]]></xsd:documentation>
418+
</xsd:annotation>
419+
</xsd:attribute>
420+
<xsd:attribute name="embedded-headers-mapper" type="xsd:string">
421+
<xsd:annotation>
422+
<xsd:documentation><![CDATA[
423+
'org.springframework.integration.mapping.OutboundMessageMapper<byte[]>' bean reference
424+
for embedding message headers into the record data together with payload.
425+
]]></xsd:documentation>
426+
<xsd:appinfo>
427+
<tool:annotation kind="ref">
428+
<tool:expected-type type="org.springframework.integration.mapping.OutboundMessageMapper"/>
429+
</tool:annotation>
430+
</xsd:appinfo>
431+
</xsd:annotation>
432+
</xsd:attribute>
433+
<xsd:attribute name="message-converter" type="xsd:string">
434+
<xsd:annotation>
435+
<xsd:documentation><![CDATA[
436+
'org.springframework.messaging.converter.MessageConverter' bean reference
437+
for converting payload to 'byte[]' for Kinesis record.
438+
]]></xsd:documentation>
439+
<xsd:appinfo>
440+
<tool:annotation kind="ref">
441+
<tool:expected-type type="org.springframework.messaging.converter.MessageConverter"/>
442+
</tool:annotation>
443+
</xsd:appinfo>
444+
</xsd:annotation>
445+
</xsd:attribute>
446+
</xsd:extension>
447+
</xsd:complexContent>
448+
</xsd:complexType>
449+
</xsd:element>
450+
337451
<xsd:element name="s3-inbound-channel-adapter">
338452
<xsd:annotation>
339453
<xsd:documentation><![CDATA[

0 commit comments

Comments
 (0)