---
schema_version: "1"
id: 42dc48d7595d3dee75dd56d02839758d02f72ce2926c07cf433a069faee88c42
title: Amazon Kinesis Data Streams Connector 2.0 Reference
collection: mulesoft
version: current
locale: en-us
portal_url: https://docs.salesforce.com/mulesoft/current/en-us/amazon-kinesis-connector/latest/amazon-kinesis-connector-reference.md
canonical_url: https://docs.mulesoft.com/amazon-kinesis-connector/latest/amazon-kinesis-connector-reference
source_site: docs.mulesoft.com
content_type: documentation
content_hash: a1ae1874ec18a67044f27a32dcdd2f05aa6c606f02d1ae64405ece08b3c01546
description: MuleSoft Documentation Site
release: "2.0"
latest: true
---
---
product: Amazon Kinesis Connector
version: 2.0
is-latest-version: true
---

# Amazon Kinesis Data Streams Connector 2.0 Reference

> For the full documentation index, see: https://docs.mulesoft.com/llms.txt

> [!NOTE] Amazon Kinesis Data Streams Connector doesn’t support Windows because it uses the Kinesis
> Producer Library (KPL), which deprecated Windows support starting in version 0.14.0.

## Configurations

---

### Config

The configuration for the connector. You can use this configuration for both the producer and
consumer.

#### Parameters

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p>Name</p></td><td><p>String</p></td><td><p>The name for this configuration. Connectors reference the configuration with this name.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Connection</p></td><td><div><div><p><a href="#Config_Connection">Kinesis Connection</a></p></div></div></td><td><p>The connection types to provide to this configuration.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Name</p></td><td><div><div><p>String</p></div></div></td><td><p>The identifier of this element used to reference it in other components.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Expiration Policy</p></td><td><div><div><p><a href="#ExpirationPolicy">Expiration Policy</a></p></div></div></td><td><p>Configures the minimum amount of time that a dynamic configuration instance can remain idle before the runtime considers it eligible for expiration. This does not mean that the platform will expire the instance at the exact moment that it becomes eligible. The runtime will actually purge the instances when it sees it fit.</p></td><td></td><td></td></tr><tr><td><p>Aggregation Enabled</p></td><td><div><div><p>Boolean</p></div></div></td><td><p>When set to <code>true</code>, this option packs multiple user data records into a single Amazon Kinesis data record.</p></td><td><p>true</p></td><td></td></tr><tr><td><p>Response Timeout</p></td><td><div><div><p>Number</p></div></div></td><td><p>The maximum total time that can elapse between the start of an HTTP request and when the responses are received. If this time is exceeded, the request times out.</p></td><td><p>30</p></td><td></td></tr><tr><td><p>Request Timeout Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>A time unit that qualifies the <strong>Response Timeout</strong> value</p></td><td><p>SECONDS</p></td><td></td></tr><tr><td><p>Record Max Buffered Time</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum amount of time that an Amazon Kinesis data record spends buffering before it is sent. Records can be sent earlier than this value, depending on other buffering limits.</p></td><td><p>100</p></td><td></td></tr><tr><td><p>Record Max Buffered Time Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>A time unit that qualifies the <strong>Record Max Buffered Time</strong> value</p></td><td><p>MILLISECONDS</p></td><td></td></tr><tr><td><p>Aggregation Max Count</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum number of items to pack into an aggregated Amazon Kinesis data record.</p></td><td><p>4294967295</p></td><td></td></tr><tr><td><p>Aggregation Max Size</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum data size to pack into an aggregated Amazon Kinesis data record.</p></td><td><p>51200</p></td><td></td></tr><tr><td><p>Aggregation Max Size Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><p>A data unit that qualifies the <strong>Aggregation Max Size</strong> value</p></td><td><p>BYTE</p></td><td></td></tr><tr><td><p>Collection Max Count</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum number of items to pack into a batch request.</p></td><td><p>500</p></td><td></td></tr><tr><td><p>Collection Max Size</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum amount of data to send with a <strong>Put Record</strong> operation.</p></td><td><p>5242880</p></td><td></td></tr><tr><td><p>Collection Max Size Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><p>A data unit that qualifies the <strong>Collection Max Size</strong> value</p></td><td><p>BYTE</p></td><td></td></tr><tr><td><p>Connection Timeout</p></td><td><div><div><p>Number</p></div></div></td><td><p>The amount of time to wait when initially establishing the TCP connection between the connector and Amazon Kinesis server before throwing an exception if the connection fails</p></td><td><p>30</p></td><td></td></tr><tr><td><p>Connection Timeout Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>The time unit for the <strong>Connection Timeout</strong> value</p></td><td><p>SECONDS</p></td><td></td></tr><tr><td><p>Max Connections</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum number of connections to open to the backend. HTTP requests are sent in parallel over multiple connections. Setting this value too high can impact latency and consume additional resources without increasing throughput.</p></td><td><p>24</p></td><td></td></tr><tr><td><p>Min Connections</p></td><td><div><div><p>Number</p></div></div></td><td><p>Minimum number of connections to keep open to the backend. In most cases, there is no need to increase value.</p></td><td><p>1</p></td><td></td></tr><tr><td><p>Rate Limit</p></td><td><div><div><p>Number</p></div></div></td><td><p>Limits the number of data records per second and number of bytes per second sent to a shard. This limit can reduce bandwidth and CPU cycle wastage from sending requests that will fail from throttling. The default value, 150%, enables a single producer instance to completely saturate the allowance for a shard. To reduce throttling errors rather than completely saturate the shard, consider reducing this setting.</p></td><td><p>150%</p></td><td></td></tr><tr><td><p>Record TTL</p></td><td><div><div><p>Number</p></div></div></td><td><p>Time limit for data records to be put. Records that are not successfully put within this limit fail. When setting this value, take into consideration the fact that data records still incur network latency after they leave the Amazon Kinesis Producer Library (KPL).</p></td><td><p>30</p></td><td></td></tr><tr><td><p>Record TTL Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>The time unit for the <strong>Record TTL</strong> value.</p></td><td><p>SECONDS</p></td><td></td></tr><tr><td><p>Thread Pool Size</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum number of threads with which to configure the native process thread pool. The default value, 0, enables the KPL process to choose the size of the thread pool.</p></td><td><p>0</p></td><td></td></tr></tbody></table>

#### Connection Types

##### Kinesis Connection

Connects to AWS Kinesis through the use of a user-specified access and secret key and, optionally, a
role. These credentials securely sign requests sent to AWS services.

###### Parameters

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p>Custom Kinesis Endpoint</p></td><td><div><div><p>String</p></div></div></td><td><p>Specifies a custom Kinesis endpoint, often used for FIPS compliance.</p></td><td></td><td></td></tr><tr><td><p>Custom STS endpoint</p></td><td><div><div><p>String</p></div></div></td><td><p>Sets a custom STS endpoint. This is useful when a non-standard service endpoint is required, such as a VPC endpoint or a FIPS-compliant endpoint.</p></td><td></td><td></td></tr><tr><td><p>Proxy Configuration</p></td><td><div><div><p><a href="#ProxyConfiguration">Proxy Configuration</a></p></div></div></td><td><p>Proxy connection settings for outbound connections. This setting applies to the <strong>Listener</strong> source and <strong>Checkpoint</strong> operation. It does not affect the <strong>Put Record</strong> operation.</p></td><td></td><td></td></tr><tr><td><p>TLS Configuration</p></td><td><div><div><p><a href="#Tls">TLS</a></p></div></div></td><td><p>Protocol to use for communication. When using the HTTPS protocol, the HTTP communication is secured using TLS or SSL. If HTTPS is configured as the protocol, then, at a minimum, you must configure the keystore in the <code>tls:context</code> child element of the <code>listener-config</code>.<br><br>This setting applies to the <strong>Listener</strong> source and <strong>Checkpoint</strong> operation. It does not affect the <strong>Put Record</strong> operation.</p></td><td></td><td></td></tr><tr><td><p>Access Key</p></td><td><div><div><p>String</p></div></div></td><td><p>Access key provided by Amazon.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Secret Key</p></td><td><div><div><p>String</p></div></div></td><td><p>Secret key provided by Amazon.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Region Endpoint</p></td><td><div><div><p>String</p></div></div></td><td><p>Topic region endpoint</p></td><td><p>us-east-1</p></td><td></td></tr><tr><td><p>Role</p></td><td><div><div><p><a href="#Role">Role</a></p></div></div></td><td><p>Role configuration</p></td><td></td><td></td></tr><tr><td><p>Custom Dynamo DB Endpoint</p></td><td><div><div><p>String</p></div></div></td><td><p>Sets a Dynamo DB endpoint to track and maintain state information.</p></td><td></td><td></td></tr><tr><td><p>Custom Cloud Watch Endpoint</p></td><td><div><div><p>String</p></div></div></td><td><p>Sets a Cloud Watch endpoint for monitoring and observability.</p></td><td></td><td></td></tr><tr><td><p>Connection Timeout</p></td><td><div><div><p>Number</p></div></div></td><td><p>The amount of time to wait when initially establishing the TCP connection between the connector and Amazon Kinesis server before throwing an exception if the connection fails</p></td><td><p>30</p></td><td></td></tr><tr><td><p>Connection Timeout Time Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>The time unit for the <strong>Connection Timeout</strong> field.</p></td><td><p>SECONDS</p></td><td></td></tr><tr><td><p>Response Timeout</p></td><td><div><div><p>Number</p></div></div></td><td><p>The maximum time to wait between the time an HTTP request is sent and when a response is received</p></td><td><p>30</p></td><td></td></tr><tr><td><p>Response Timeout Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>Time unit for the <strong>Response Timeout</strong> value.</p></td><td><p>SECONDS</p></td><td></td></tr><tr><td><p>Reconnection</p></td><td><div><div><p><a href="#Reconnection">Reconnection</a></p></div></div></td><td><p>When the application is deployed, a connectivity test is performed on all connectors. If set to <code>true</code>, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.</p></td><td></td><td></td></tr></tbody></table>

## Supported Operations

- [Checkpoint](#Checkpoint)

- [Put Record](#PutRecord)

## Associated Sources

- [Listener](#Listener)

## Operations

## Checkpoint

`<kinesis:checkpoint>`

The operation checkpoint position of a listener into the Amazon DynamoDB table. Upon failover, the
connector starts fetching records that are located after the check pointed position. The
**Checkpoint** operation does not modify the current position of the listener.

### Parameters

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p>Configuration</p></td><td><p>String</p></td><td><p>The name of the configuration to use.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Stream Name</p></td><td><div><div><p>String</p></div></div></td><td><p>The stream name.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Application Name</p></td><td><div><div><p>String</p></div></div></td><td><p>Name of the DynamoDB table that holds data about the current stream positions.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Shard ID</p></td><td><div><div><p>String</p></div></div></td><td><p>The shard identifier.</p></td><td></td><td></td></tr><tr><td><p>Sequence Number</p></td><td><div><div><p>String</p></div></div></td><td><p>A sequence number at which to checkpoint in the shard.</p></td><td></td><td></td></tr><tr><td><p>Subsequence Number</p></td><td><div><div><p>Number</p></div></div></td><td><p>A subsequence number at which to checkpoint within the shard.</p></td><td></td><td></td></tr><tr><td><p>Config Ref</p></td><td><div><div><p>ConfigurationProvider</p></div></div></td><td><p>The name of the configuration to use to execute this component</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Error Mappings</p></td><td><div><div><p>Array of <a href="#ErrorMapping">Error Mapping</a></p></div></div></td><td><p>Set of error mappings.</p></td><td></td><td></td></tr></tbody></table>

### For Configurations

- [Config](#Config)

### Throws

- KINESIS:ILLEGAL\_STATE

- KINESIS:INVALID\_ARGUMENT

- KINESIS:PROVISIONED\_THROUGHPUT\_EXCEEDED

- KINESIS:TIMEOUT

- KINESIS:UNAUTHORIZED

## Put Record

`<kinesis:put-record>`

Puts a data record into an Amazon Kinesis data stream.

### Parameters

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p>Configuration</p></td><td><p>String</p></td><td><p>The name of the configuration to use.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Stream Name</p></td><td><div><div><p>String</p></div></div></td><td><p>The stream name</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Partition Key</p></td><td><div><div><p>String</p></div></div></td><td><p>The partition key. If not provided, the connector generates a UUID for this value.</p></td><td></td><td></td></tr><tr><td><p>Explicit Hash Key</p></td><td><div><div><p>String</p></div></div></td><td><p>Overrides the Amazon Kinesis Data Streams explicitHashKey value, which is normally computed with using MD5 function of the data record partition key.</p></td><td></td><td></td></tr><tr><td><p>Data</p></td><td><div><div><p>Any</p></div></div></td><td><p>The content to put in the Amazon Kinesis data stream. This content can be up to 1 MB in size.</p></td><td><p>#[payload]</p></td><td></td></tr><tr><td><p>Config Ref</p></td><td><div><div><p>ConfigurationProvider</p></div></div></td><td><p>The name of the configuration to use to execute this component</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Streaming Strategy</p></td><td><div><div><ul><li><p><a href="#RepeatableInMemoryStream">Repeatable In Memory Stream</a></p></li><li><p><a href="#RepeatableFileStoreStream">Repeatable File Store Stream</a></p></li><li><p>non-repeatable-stream</p></li></ul></div></div></td><td><p>Disables the repeatable stream functionality and uses non-repeatable streams to have lower performance overhead, memory use, and costs</p></td><td></td><td></td></tr><tr><td><p>Target Variable</p></td><td><div><div><p>String</p></div></div></td><td><p>Name of the variable in which to store the operation’s output</p></td><td></td><td></td></tr><tr><td><p>Target Value</p></td><td><div><div><p>String</p></div></div></td><td><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></td><td><p>#[payload]</p></td><td></td></tr><tr><td><p>Error Mappings</p></td><td><div><div><p>Array of <a href="#ErrorMapping">Error Mapping</a></p></div></div></td><td><p>Set of error mappings.</p></td><td></td><td></td></tr><tr><td><p>Reconnection Strategy</p></td><td><div><div><ul><li><p><a href="#Reconnect">Reconnect</a></p></li><li><p><a href="#ReconnectForever">Reconnect Forever</a></p></li></ul></div></div></td><td><p>A retry strategy in case of connectivity errors</p></td><td></td><td></td></tr></tbody></table>

### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Any</p></td></tr></tbody></table>

### For Configurations

- [Config](#Config)

### Throws

- KINESIS:CONNECTIVITY

- KINESIS:INVALID\_ARGUMENT

- KINESIS:PROCESSING

- KINESIS:RETRY\_EXHAUSTED

- KINESIS:TIMEOUT

- KINESIS:UNAUTHORIZED

## Sources

## Listener

`<kinesis:listener>`

Uses the Amazon Kinesis Client Library (KCL) to listen from a specified point in a stream.

> [!NOTE] Due to varying batch sizes, checkpoints can occur in the incorrect sequence, potentially
> leading to transaction loss in certain cases. Set `maxConcurrency=1` to ensure transactions are
> processed sequentially.

### Parameters

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p>Configuration</p></td><td><p>String</p></td><td><p>The name of the configuration to use.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Output Mime Type</p></td><td><div><div><p>String</p></div></div></td><td><p>The MIME type of the payload that this operation outputs.</p></td><td></td><td></td></tr><tr><td><p>Output Encoding</p></td><td><div><div><p>String</p></div></div></td><td><p>The encoding of the payload that this operation outputs.</p></td><td></td><td></td></tr><tr><td><p>Config Ref</p></td><td><div><div><p>ConfigurationProvider</p></div></div></td><td><p>The name of the configuration to use to execute this component</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Primary Node Only</p></td><td><div><div><p>Boolean</p></div></div></td><td><p>Whether this listener executes on the primary node only when running in a cluster</p></td><td></td><td></td></tr><tr><td><p>On Capacity Overload</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>WAIT</p></li><li><p>DROP</p></li></ul></div></div></td><td><p>Strategy that Mule applies when the flow receives more messages than it can handle</p></td><td><p>WAIT</p></td><td></td></tr><tr><td><p>Primary Node Only</p></td><td><div><div><p>Boolean</p></div></div></td><td><p>Set to true to restrict the execution of this source to the primary node when operating in a cluster environment.</p></td><td></td><td></td></tr><tr><td><p>Config Ref</p></td><td><div><div><p>ConfigurationProvider</p></div></div></td><td><p>The name of the configuration to be used to execute this component.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Redelivery Policy</p></td><td><div><div><p><a href="#RedeliveryPolicy">Redelivery Policy</a></p></div></div></td><td><p>Policy for processing the redelivery of a message</p></td><td></td><td></td></tr><tr><td><p>Stream Name</p></td><td><div><div><p>String</p></div></div></td><td><p>The stream name.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Application Name</p></td><td><div><div><p>String</p></div></div></td><td><p>Name of the DynamoDB table that holds data about current stream positions. If the table doesn’t exist, then the connector creates a new one at the initial position.</p></td><td></td><td><p>x</p></td></tr><tr><td><p>Shard Configs</p></td><td><div><div><p>Array of <a href="#ShardConfig">Shard Config</a></p></div></div></td><td><p>The shard configuration. If specified, the listener listens only from selected shards.</p></td><td></td><td></td></tr><tr><td><p>Max Batch Size</p></td><td><div><div><p>Number</p></div></div></td><td><p>Maximum number of data records a batch can carry. A batch is the number of records that the listener receives from the stream.</p></td><td><p>10000</p></td><td></td></tr><tr><td><p>Max Leases For Worker</p></td><td><div><div><p>Number</p></div></div></td><td><p>Number of shards to which the listener can subscribe in parallel.</p></td><td><p>2137483647</p></td><td></td></tr><tr><td><p>Shard Prioritization</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>PARENTS_FIRST_SHARD_PRIORITIZATION</p></li><li><p>NO_OP_SHARD_PRIORITIZATION</p></li></ul></div></div></td><td><p>Logic used to prioritize or filter the shards before their execution.<br><br>PARENTS_FIRST_SHARD_PRIORITIZATION Prioritizes parent shards first and limits the number of shards that are available for initialization based on their depth (<strong>Max Depth</strong> field).</p><p>NO_OP_SHARD_PRIORITIZATION Returns the original list of shards without any modifications.</p></td><td><p>NO_OP_SHARD_PRIORITIZATION</p></td><td></td></tr><tr><td><p>Max Depth</p></td><td><div><div><p>Number</p></div></div></td><td><p>Used by the PARENTS_FIRST_SHARD_PRIORITIZATION shard prioritization option. Any shard that is deeper than this value is excluded from processing.</p></td><td></td><td></td></tr><tr><td><p>Read Capacity Units</p></td><td><div><div><p>Number</p></div></div></td><td><p>The maximum number of strongly consistent reads consumed per second before Amazon DynamoDB returns a ThrottlingException.</p></td><td><p>10</p></td><td></td></tr><tr><td><p>Write Capacity Units</p></td><td><div><div><p>Number</p></div></div></td><td><p>The maximum number of writes consumed per second before Amazon DynamoDB returns a ThrottlingException.</p></td><td><p>10</p></td><td></td></tr><tr><td><p>Failover Time</p></td><td><div><div><p>Number</p></div></div></td><td><p>Duration of a lease for a worker. This parameter also determines the frequency with which a worker looks for new leases to work on. The frequency is roughly twice the specified value.</p></td><td><p>10</p></td><td></td></tr><tr><td><p>Failover Time Unit</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><p>Time unit for the <strong>Failover Time</strong> field.</p></td><td><p>SECONDS</p></td><td></td></tr><tr><td><p>Checkpoint On Complete</p></td><td><div><div><p>Boolean</p></div></div></td><td><p>If <code>true</code>, the listener checkpoints the current reading position to Amazon DynamoDB after data records are processed by the owning flow, without taking into account whether the processing finished successfully.</p></td><td><p>true</p></td><td></td></tr><tr><td><p>Absolute Position</p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>LATEST</p></li><li><p>FIRST</p></li></ul></div></div></td><td><p>Whether the listener listens from the latest data record or the oldest data record</p></td><td></td><td></td></tr><tr><td><p>Timestamp</p></td><td><div><div><p>DateTime</p></div></div></td><td><p>Date and time from which the listener listens</p></td><td></td><td></td></tr><tr><td><p>Reconnection Strategy</p></td><td><div><div><ul><li><p><a href="#Reconnect">Reconnect</a></p></li><li><p><a href="#ReconnectForever">Reconnect Forever</a></p></li></ul></div></div></td><td><p>A retry strategy in case of connectivity errors</p></td><td></td><td></td></tr></tbody></table>

### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Array of binary messages with [<a href="#RecordAttributes">Record Attributes</a>]</p></td></tr></tbody></table>

### For Configurations

- [Config](#Config)

## Types

### Proxy Configuration

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Host</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Host where the proxy requests are sent.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Port</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Port where the proxy requests are sent.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Username</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The username to authenticate against the proxy.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The password to authenticate against the proxy.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Non Proxy Hosts</strong></p></td><td><div><div><p>Array of String</p></div></div></td><td><div><div><p>A list of hosts against which the proxy should not be used.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Ntlm Domain</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The domain to authenticate against the proxy.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### TLS

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Enabled Protocols</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>A comma-separated list of protocols enabled for this context.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Enabled Cipher Suites</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>A comma-separated list of cipher suites enabled for this context.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Trust Store</strong></p></td><td><div><div><p><a href="#TrustStore">Trust Store</a></p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Key Store</strong></p></td><td><div><div><p><a href="#KeyStore">Key Store</a></p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Revocation Check</strong></p></td><td><div><div><ul><li><p><a href="#StandardRevocationCheck">Standard Revocation Check</a></p></li><li><p><a href="#CustomOcspResponder">Custom Ocsp Responder</a></p></li><li><p><a href="#CrlFile">Crl File</a></p></li></ul></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Trust Store

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The location (which is resolved relative to the current classpath and file system, if possible) of the truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The password used to protect the truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Type</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The type of store used.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Algorithm</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The algorithm used by the truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Insecure</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>If set to <code>true</code>, no certificate validations are performed, which makes connections vulnerable to attacks. Use at your own risk.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Key Store

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The location (which is resolved relative to the current classpath and file system, if possible) of the keystore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Type</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The type of store used.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Alias</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>When the keystore contains many private keys, this attribute indicates the alias of the key that should be used. If not defined, the first key in the file is used by default.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Key Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The password used to protect the private key.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The password used to protect the keystore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Algorithm</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The algorithm used by the keystore.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Standard Revocation Check

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Only End Entities</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Verifies the last element of the certificate chain only.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Prefer Crls</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Tries CRL instead of OCSP first.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>No Fallback</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Does not use the secondary checking method.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Soft Fail</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Avoids a certification failure when the revocation server cannot be reached or is busy.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Custom Ocsp Responder

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Url</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The URL of the OCSP responder.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Cert Alias</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Alias of the signing certificate for the OCSP response (must be in the truststore), if present.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Crl File

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The path to the CRL file.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Role

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Arn</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The Amazon Resource Name (ARN) of the role to assume.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>External Id</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>A unique identifier that might be required when you assume a role in another account. If the administrator of the account to which the role belongs provides an external ID, then provide that value in this field.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Duration</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>The duration of the role session.</p></div></div></td><td><div><div><p>3600</p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Duration Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Duration</strong> field</p></div></div></td><td><div><div><p>SECONDS</p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Referred Policy Arns</strong></p></td><td><div><div><p>Array of String</p></div></div></td><td><div><div><p>The Amazon Resource Names (ARNs) of the IAM-managed policies to use as managed session policies. The policies must exist in the same account as the role.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Tags</strong></p></td><td><div><div><p>Object</p></div></div></td><td><div><div><p>A list of session tags that you want to pass. Each session tag consists of a key name and an associated value.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Reconnection

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Fails Deployment</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>When the application is deployed, a connectivity test is performed on all connectors. If set to <code>true</code>, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#Reconnect">Reconnect</a></p></li><li><p><a href="#ReconnectForever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>The reconnection strategy to use.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Reconnect

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Frequency</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How often in milliseconds to reconnect</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Blocking</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>If false, the reconnection strategy runs in a separate, non-blocking thread.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Count</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How many reconnection attempts to make.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Reconnect Forever

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Frequency</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How often in milliseconds to reconnect</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Blocking</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>If false, the reconnection strategy runs in a separate, non-blocking thread.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Expiration Policy

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Max Idle Time</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>A scalar time value for the maximum amount of time a dynamic configuration instance should be allowed to be idle before it’s considered eligible for expiration.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>A time unit that qualifies the <strong>Max Idle Time</strong> attribute.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Record Attributes

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Aggregated</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Approximate Arrival Timestamp</strong></p></td><td><div><div><p>String</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Encryption Type</strong></p></td><td><div><div><p>String</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Partition Key</strong></p></td><td><div><div><p>String</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Sequence Number</strong></p></td><td><div><div><p>String</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Shard Id</strong></p></td><td><div><div><p>String</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Sub Sequence Number</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Redelivery Policy

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Max Redelivery Count</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>The maximum number of times a message can be redelivered and processed unsuccessfully before triggering a process-failed message.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Message Digest Algorithm</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The secure hashing algorithm to use.</p></div></div></td><td><div><div><p>SHA-256</p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Message Identifier</strong></p></td><td><div><div><p><a href="#RedeliveryPolicyMessageIdentifier">Redelivery Policy Message Identifier</a></p></div></div></td><td><div><div><p>The strategy used to identify the messages.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Object Store</strong></p></td><td><div><div><p>ObjectStore</p></div></div></td><td><div><div><p>The object store that stores the redelivery counter for each message.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Redelivery Policy Message Identifier

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Use Secure Hash</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Whether to use a secure hash algorithm to identify a redelivered message.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Id Expression</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>One or more expressions to use to determine when a message was redelivered. This property can be set only if the value of the <strong>Use Secure Hash</strong> field is <code>false</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Shard Config

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Shard Id</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The shard identifier.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Shard Initial Position</strong></p></td><td><div><div><p><a href="#ShardInitialPosition">Shard Initial Position</a></p></div></div></td><td><div><div><p>The shard initial position.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr></tbody></table>

### Shard Initial Position

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>At Sequence Number</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The listener starts listening at this position in the data stream.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>After Sequence Number</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The listener starts listening after this position in the data stream.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Absolute Position</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>LATEST</p></li><li><p>FIRST</p></li></ul></div></div></td><td><div><div><p>The listener starts listening from the latest or oldest record, depending on the value.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Timestamp</strong></p></td><td><div><div><p>DateTime</p></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Error Mapping

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Source</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>ANY</p></li><li><p>REDELIVERY_EXHAUSTED</p></li><li><p>TRANSFORMATION</p></li><li><p>EXPRESSION</p></li><li><p>SECURITY</p></li><li><p>CLIENT_SECURITY</p></li><li><p>SERVER_SECURITY</p></li><li><p>ROUTING</p></li><li><p>CONNECTIVITY</p></li><li><p>RETRY_EXHAUSTED</p></li><li><p>TIMEOUT</p></li></ul></div></div></td><td><div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target</strong></p></td><td><div><div><p>String</p></div></div></td><td><div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr></tbody></table>

### Repeatable In Memory Stream

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Initial Buffer Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>The amount of memory to allocate to consume the stream and provide random access to it. If the stream contains more data than can fit into this buffer, then the buffer expands according to the <strong>Buffer Size Increment</strong> value, with an upper limit of the <strong>Max In Memory Size</strong> value.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Size Increment</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a <code>STREAM_MAXIMUM_SIZE_EXCEEDED</code> error is raised when the buffer is full.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Buffer Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>The maximum amount of memory to use. If more memory is used, then a <code>STREAM_MAXIMUM_SIZE_EXCEEDED</code> error is raised. A value less than or equal to zero means no limit.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><div><div><p>The unit in which the fields in this table are expressed</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Repeatable File Store Stream

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>In Memory Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum memory that the stream should use to keep data in memory. If more than that is consumed, content on the disk is buffered.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><div><div><p>The unit in which the <strong>In Memory Size</strong> value is expressed</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

## See Also

- [Introduction to Anypoint Connectors](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors)

- [Reference](#)

- [Salesforce Help](https://help.salesforce.com)