Skip to content

Commit 94c9e84

Browse files
boolivarboolivar
committed
feat: kinesis-message-driven-channel-adapter xsd schema
1 parent e4e801a commit 94c9e84

File tree

1 file changed

+169
-0
lines changed

1 file changed

+169
-0
lines changed

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

Lines changed: 169 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,159 @@
1919
]]></xsd:documentation>
2020
</xsd:annotation>
2121

22+
<xsd:element name="kinesis-message-driven-channel-adapter">
23+
<xsd:annotation>
24+
<xsd:documentation><![CDATA[
25+
Configures an 'KinesisMessageDrivenChannelAdapter' endpoint
26+
receiving data from Amazon Kinesis streams.
27+
]]></xsd:documentation>
28+
</xsd:annotation>
29+
<xsd:complexType>
30+
<xsd:attributeGroup ref="inboundChannelAdapterAttributes"/>
31+
<xsd:attribute name="kinesis-client" type="xsd:string" use="required">
32+
<xsd:annotation>
33+
<xsd:documentation><![CDATA[
34+
The 'software.amazon.awssdk.services.kinesis.KinesisAsyncClient' bean reference.
35+
]]></xsd:documentation>
36+
<xsd:appinfo>
37+
<tool:annotation kind="ref">
38+
<tool:expected-type type="software.amazon.awssdk.services.kinesis.KinesisAsyncClient"/>
39+
</tool:annotation>
40+
</xsd:appinfo>
41+
</xsd:annotation>
42+
</xsd:attribute>
43+
<xsd:attribute name="streams" type="xsd:string" use="required">
44+
<xsd:annotation>
45+
<xsd:documentation><![CDATA[
46+
Comma-separated list of streams.
47+
]]></xsd:documentation>
48+
</xsd:annotation>
49+
</xsd:attribute>
50+
<xsd:attribute name="consumer-group" type="xsd:string">
51+
<xsd:annotation>
52+
<xsd:documentation><![CDATA[
53+
Name of the group this consumer belongs to.
54+
]]></xsd:documentation>
55+
</xsd:annotation>
56+
</xsd:attribute>
57+
<xsd:attribute name="bind-source-record" type="xsd:boolean">
58+
<xsd:annotation>
59+
<xsd:documentation><![CDATA[
60+
Bind the source consumer record in the header named
61+
'IntegrationMessageHeaderAccessor.SOURCE_DATA'.
62+
Does not apply to batch listeners.
63+
]]></xsd:documentation>
64+
</xsd:annotation>
65+
</xsd:attribute>
66+
<xsd:attribute name="checkpoint-mode">
67+
<xsd:annotation>
68+
<xsd:documentation><![CDATA[
69+
Default is 'batch'.
70+
]]></xsd:documentation>
71+
</xsd:annotation>
72+
<xsd:simpleType>
73+
<xsd:union memberTypes="kinesisCheckpointMode xsd:string"/>
74+
</xsd:simpleType>
75+
</xsd:attribute>
76+
<xsd:attribute name="checkpoints-interval" type="xsd:long">
77+
<xsd:annotation>
78+
<xsd:documentation><![CDATA[
79+
Sets the interval between 2 checkpoints.
80+
Only used when checkpointMode is periodic.
81+
]]></xsd:documentation>
82+
</xsd:annotation>
83+
</xsd:attribute>
84+
<xsd:attribute name="lock-renewal-timeout" type="xsd:long">
85+
<xsd:annotation>
86+
<xsd:documentation><![CDATA[
87+
Configure a timeout in milliseconds
88+
to wait for lock on shard renewal.
89+
]]></xsd:documentation>
90+
</xsd:annotation>
91+
</xsd:attribute>
92+
<xsd:attribute name="concurrency" type="xsd:int">
93+
<xsd:annotation>
94+
<xsd:documentation><![CDATA[
95+
The maximum number of concurrent 'ConsumerInvoker's running.
96+
The 'ShardConsumer' are evenly distributed between 'ConsumerInvoker's.
97+
Messages from within the same shard will be processed sequentially.
98+
In other words each shard is tied with the particular thread.
99+
By default the concurrency is unlimited and shard is processed
100+
in the 'consumerExecutor' directly.
101+
]]></xsd:documentation>
102+
</xsd:annotation>
103+
</xsd:attribute>
104+
<xsd:attribute name="consumer-backoff" type="xsd:int">
105+
<xsd:annotation>
106+
<xsd:documentation><![CDATA[
107+
Sleep timeout in milliseconds if consumer is throttled.
108+
]]></xsd:documentation>
109+
</xsd:annotation>
110+
</xsd:attribute>
111+
<xsd:attribute name="idle-between-polls" type="xsd:int">
112+
<xsd:annotation>
113+
<xsd:documentation><![CDATA[
114+
The sleep interval in milliseconds used in the
115+
main loop between shards polling cycles.
116+
Defaults to 1000. Minimum is 250.
117+
]]></xsd:documentation>
118+
</xsd:annotation>
119+
</xsd:attribute>
120+
<xsd:attribute name="listener-mode">
121+
<xsd:annotation>
122+
<xsd:documentation><![CDATA[
123+
Default is 'record'.
124+
]]></xsd:documentation>
125+
</xsd:annotation>
126+
<xsd:simpleType>
127+
<xsd:union memberTypes="kinesisListenerMode xsd:string"/>
128+
</xsd:simpleType>
129+
</xsd:attribute>
130+
<xsd:attribute name="records-limit" type="xsd:int">
131+
<xsd:annotation>
132+
<xsd:documentation><![CDATA[
133+
The maximum record to poll per on get-records request.
134+
Not greater then 10000.
135+
Default is 10000.
136+
]]></xsd:documentation>
137+
</xsd:annotation>
138+
</xsd:attribute>
139+
<xsd:attribute name="start-timeout" type="xsd:int">
140+
<xsd:annotation>
141+
<xsd:documentation><![CDATA[
142+
Max timeout in milliseconds to start.
143+
Default is 60s.
144+
]]></xsd:documentation>
145+
</xsd:annotation>
146+
</xsd:attribute>
147+
<xsd:attribute name="checkpoint-store" type="xsd:string">
148+
<xsd:annotation>
149+
<xsd:documentation><![CDATA[
150+
The 'org.springframework.integration.metadata.ConcurrentMetadataStore' bean reference.
151+
]]></xsd:documentation>
152+
<xsd:appinfo>
153+
<tool:annotation kind="ref">
154+
<tool:expected-type type="org.springframework.integration.metadata.ConcurrentMetadataStore"/>
155+
</tool:annotation>
156+
</xsd:appinfo>
157+
</xsd:annotation>
158+
</xsd:attribute>
159+
<xsd:attribute name="lock-registry" type="xsd:string">
160+
<xsd:annotation>
161+
<xsd:documentation><![CDATA[
162+
The 'org.springframework.integration.support.locks.LockRegistry'
163+
bean reference for exclusive access to provided streams.
164+
]]></xsd:documentation>
165+
<xsd:appinfo>
166+
<tool:annotation kind="ref">
167+
<tool:expected-type type="org.springframework.integration.support.locks.LockRegistry"/>
168+
</tool:annotation>
169+
</xsd:appinfo>
170+
</xsd:annotation>
171+
</xsd:attribute>
172+
</xsd:complexType>
173+
</xsd:element>
174+
22175
<xsd:element name="s3-inbound-channel-adapter">
23176
<xsd:annotation>
24177
<xsd:documentation><![CDATA[
@@ -1000,6 +1153,22 @@
10001153
</xsd:attribute>
10011154
</xsd:attributeGroup>
10021155

1156+
<xsd:simpleType name="kinesisCheckpointMode">
1157+
<xsd:restriction base="xsd:token">
1158+
<xsd:enumeration value="record"/>
1159+
<xsd:enumeration value="batch"/>
1160+
<xsd:enumeration value="manual"/>
1161+
<xsd:enumeration value="periodic"/>
1162+
</xsd:restriction>
1163+
</xsd:simpleType>
1164+
1165+
<xsd:simpleType name="kinesisListenerMode">
1166+
<xsd:restriction base="xsd:token">
1167+
<xsd:enumeration value="record"/>
1168+
<xsd:enumeration value="batch"/>
1169+
</xsd:restriction>
1170+
</xsd:simpleType>
1171+
10031172
<xsd:simpleType name="s3CommandType">
10041173
<xsd:restriction base="xsd:token">
10051174
<xsd:enumeration value="UPLOAD"/>

0 commit comments

Comments
 (0)