You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The identifier for the Kafka consumer group to join\. The consumer group ID must be unique among all your Kafka event sources\. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value\. For more information, see [Customizable consumer group ID](https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html#services-msk-consumer-group-id)\.
9
+
Type: String
10
+
Length Constraints: Minimum length of 1\. Maximum length of 200\.
11
+
Pattern: `[a-zA-Z0-9-\/*:_+=.@-]*`
12
+
Required: No
13
+
14
+
## See Also<aname="API_AmazonManagedKafkaEventSourceConfig_SeeAlso"></a>
15
+
16
+
For more information about using this API in one of the language\-specific AWS SDKs, see the following:
17
+
+[AWS SDK for C\+\+](https://docs.aws.amazon.com/goto/SdkForCpp/lambda-2015-03-31/AmazonManagedKafkaEventSourceConfig)
18
+
+[AWS SDK for Go](https://docs.aws.amazon.com/goto/SdkForGoV1/lambda-2015-03-31/AmazonManagedKafkaEventSourceConfig)
19
+
+[AWS SDK for Java V2](https://docs.aws.amazon.com/goto/SdkForJavaV2/lambda-2015-03-31/AmazonManagedKafkaEventSourceConfig)
20
+
+[AWS SDK for Ruby V3](https://docs.aws.amazon.com/goto/SdkForRubyV3/lambda-2015-03-31/AmazonManagedKafkaEventSourceConfig)
Creates a code signing configuration\. A [code signing configuration](https://docs.aws.amazon.com/lambda/latest/dg/configuration-trustedcode.html) defines a list of allowed signing profiles and defines the code\-signing validation policy \(action to be taken if deployment validation checks fail\)\.
3
+
Creates a code signing configuration\. A [code signing configuration](https://docs.aws.amazon.com/lambda/latest/dg/configuration-codesigning.html) defines a list of allowed signing profiles and defines the code\-signing validation policy \(action to be taken if deployment validation checks fail\)\.
The following error handling options are only available for stream sources \(DynamoDB and Kinesis\):
13
+
The following error handling options are available only for stream sources \(DynamoDB and Kinesis\):
14
14
+`BisectBatchOnFunctionError`\- If the function returns an error, split the batch in two and retry\.
15
15
+`DestinationConfig`\- Send discarded records to an Amazon SQS queue or Amazon SNS topic\.
16
16
+`MaximumRecordAgeInSeconds`\- Discard records older than the specified age\. The default value is infinite \(\-1\)\. When set to infinite \(\-1\), failed records are retried until the record expires
@@ -32,6 +32,9 @@ POST /2015-03-31/event-source-mappings/ HTTP/1.1
32
32
Content-type: application/json
33
33
34
34
{
35
+
"AmazonManagedKafkaEventSourceConfig": {
36
+
"ConsumerGroupId": "string"
37
+
},
35
38
"BatchSize": number,
36
39
"BisectBatchOnFunctionError": boolean,
37
40
"DestinationConfig": {
@@ -63,6 +66,9 @@ Content-type: application/json
63
66
"string" : [ "string" ]
64
67
}
65
68
},
69
+
"SelfManagedKafkaEventSourceConfig": {
70
+
"ConsumerGroupId": "string"
71
+
},
66
72
"SourceAccessConfigurations": [
67
73
{
68
74
"Type": "string",
@@ -84,13 +90,18 @@ The request does not use any URI parameters\.
84
90
85
91
The request accepts the following data in JSON format\.
The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function\. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation \(6 MB\)\.
89
100
+**Amazon Kinesis**\- Default 100\. Max 10,000\.
90
101
+**Amazon DynamoDB Streams**\- Default 100\. Max 10,000\.
91
102
+**Amazon Simple Queue Service**\- Default 10\. For standard queues the max is 10,000\. For FIFO queues the max is 10\.
92
103
+**Amazon Managed Streaming for Apache Kafka**\- Default 100\. Max 10,000\.
93
-
+**Self\-Managed Apache Kafka**\- Default 100\. Max 10,000\.
104
+
+**Self\-managed Apache Kafka**\- Default 100\. Max 10,000\.
94
105
+**Amazon MQ \(ActiveMQ and RabbitMQ\)**\- Default 100\. Max 10,000\.
95
106
Type: Integer
96
107
Valid Range: Minimum value of 1\. Maximum value of 10000\.
@@ -118,12 +129,13 @@ The Amazon Resource Name \(ARN\) of the event source\.
118
129
+**Amazon DynamoDB Streams**\- The ARN of the stream\.
119
130
+**Amazon Simple Queue Service**\- The ARN of the queue\.
120
131
+**Amazon Managed Streaming for Apache Kafka**\- The ARN of the cluster\.
\(Streams and Amazon SQS\)An object that defines the filter criteria that determine whether Lambda should process an event\. For more information, see [Lambda event filtering](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html)\.
138
+
An object that defines the filter criteria that determine whether Lambda should process an event\. For more information, see [Lambda event filtering](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html)\.
\(Streams and Amazon SQS standard queues\)The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function\.
153
-
Default: 0
154
-
Related setting: When you set `BatchSize` to a value greater than 10, you must set `MaximumBatchingWindowInSeconds` to at least 1\.
164
+
The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function\. You can configure `MaximumBatchingWindowInSeconds` to any value from 0 seconds to 300 seconds in increments of seconds\.
165
+
For streams and Amazon SQS event sources, the default batching window is 0 seconds\. For Amazon MSK, Self\-managed Apache Kafka, and Amazon MQ event sources, the default batching window is 500 ms\. Note that because you can only change `MaximumBatchingWindowInSeconds` in increments of seconds, you cannot revert back to the 500 ms default batching window after you have changed it\. To restore the default batching window, you must create a new event source mapping\.
166
+
Related setting: For streams and Amazon SQS event sources, when you set `BatchSize` to a value greater than 10, you must set `MaximumBatchingWindowInSeconds` to at least 1\.
155
167
Type: Integer
156
168
Valid Range: Minimum value of 0\. Maximum value of 300\.
157
169
Required: No
@@ -163,7 +175,7 @@ Valid Range: Minimum value of \-1\. Maximum value of 604800\.
\(Streams only\) Discard records after the specified number of retries\. The default value is infinite \(\-1\)\. When set to infinite \(\-1\), failed records will be retried until the record expires\.
178
+
\(Streams only\) Discard records after the specified number of retries\. The default value is infinite \(\-1\)\. When set to infinite \(\-1\), failed records are retried until the record expires\.
167
179
Type: Integer
168
180
Valid Range: Minimum value of \-1\. Maximum value of 10000\.
The position in a stream from which to start reading\. Required for Amazon Kinesis, Amazon DynamoDB, and Amazon MSK Streams sources\.`AT_TIMESTAMP` is only supported for Amazon Kinesis streams\.
214
+
The position in a stream from which to start reading\. Required for Amazon Kinesis, Amazon DynamoDB, and Amazon MSK Streams sources\.`AT_TIMESTAMP` is supported only for Amazon Kinesis streams\.
The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function\. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation \(6 MB\)\.
284
311
Default value: Varies by service\. For Amazon SQS, the default is 10\. For all other services, the default is 100\.
\(Streams and Amazon SQS\)An object that defines the filter criteria that determine whether Lambda should process an event\. For more information, see [Lambda event filtering](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html)\.
330
+
An object that defines the filter criteria that determine whether Lambda should process an event\. For more information, see [Lambda event filtering](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html)\.
\(Streams and Amazon SQS standard queues\)The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function\.
327
-
Default: 0
328
-
Related setting: When you set `BatchSize` to a value greater than 10, you must set `MaximumBatchingWindowInSeconds` to at least 1\.
353
+
The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function\. You can configure `MaximumBatchingWindowInSeconds` to any value from 0 seconds to 300 seconds in increments of seconds\.
354
+
For streams and Amazon SQS event sources, the default batching window is 0 seconds\. For Amazon MSK, Self\-managed Apache Kafka, and Amazon MQ event sources, the default batching window is 500 ms\. Note that because you can only change `MaximumBatchingWindowInSeconds` in increments of seconds, you cannot revert back to the 500 ms default batching window after you have changed it\. To restore the default batching window, you must create a new event source mapping\.
355
+
Related setting: For streams and Amazon SQS event sources, when you set `BatchSize` to a value greater than 10, you must set `MaximumBatchingWindowInSeconds` to at least 1\.
329
356
Type: Integer
330
357
Valid Range: Minimum value of 0\. Maximum value of 300\.
331
358
@@ -355,6 +382,10 @@ Pattern: `[\s\S]*`
355
382
The self\-managed Apache Kafka cluster for your event source\.
0 commit comments