---
schema_version: "1"
id: ac8ca0a97ce17d3b87765c26114e068f99f101b7ea9c86db59101e98ee34e4de
title: Using Anypoint Studio to Configure Apache Kafka 4.14
collection: mulesoft
version: current
locale: en-us
portal_url: https://docs.salesforce.com/mulesoft/current/en-us/kafka-connector/4.14/kafka-connector-studio.md
canonical_url: https://docs.mulesoft.com/kafka-connector/4.14/kafka-connector-studio
source_site: docs.mulesoft.com
content_type: documentation
content_hash: 8eba5f58a1236cbbb3ce711f26d475918410bb29a276486e62a9bea242824212
description: MuleSoft Documentation Site
release: "4.14"
latest: false
---
---
product: Apache Kafka Connector
version: 4.14
---

# Using Anypoint Studio to Configure Apache Kafka 4.14

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

In Anypoint Studio, add Anypoint Connector for Apache Kafka (Apache Kafka Connector) to a Mule
project, configure the connection to the Kafka cluster, and configure an input source for the
connector.

To configure a connector in Anypoint Studio:

1.  Add the connector to a Mule project.

2.  Configure the connector.

3.  Configure an input source for the connector.

## Add the Connector in Studio

1.  In Studio, create a Mule Project.

2.  In the Mule Palette, click **(X) Search in Exchange**.

3.  In **Add Modules to Project**, type the name of the connector in the search field.

4.  Click the connector name in **Available modules**.

5.  Click **Add**.

6.  Click **Finish**.

## Add the Connector Using Exchange

1.  In Studio, create a Mule Project.

2.  Click the Exchange **(X)** icon in the upper-left of the Studio task bar.

3.  In Exchange, click **Login** and supply your Anypoint Platform username and password.

4.  In Exchange, select **All assets** and search for `Apache Kafka`.

5.  Select the connector and click **Add to project**.

6.  Follow the prompts to add the connector to the Mule project.

## Consumer Configuration

You can create a consumer configuration global element to reference from Apache Kafka Connector.
This enables you to apply configuration details to multiple local elements in the flow.

1.  On the Studio canvas, click **Global Elements**.

2.  Click **Create** and expand **Connector Configuration**.

3.  Select **Apache Kafka Consumer configuration** and click **OK**.

4.  In the **Connection** field, select a connection type.

5.  Enter values for the following fields:

    <table><colgroup><col> <col> <col></colgroup><thead><tr><th>Connection Type</th><th>Field Name</th><th>Description</th></tr></thead><tbody><tr><td><p>All connection types</p></td><td><p>Bootstrap Server URLs</p></td><td><p>List of host-port pairs that establish the initial connection to the Kafka cluster. Set this value to the <code>bootstrap.servers</code> value you must provide to Kafka consumer clients.</p></td></tr><tr><td></td><td><p>Bean reference</p></td><td><p>URLs that the consumer can use to connect to the Kafka cluster</p></td></tr><tr><td></td><td><p>Group ID</p></td><td><p>Default group ID for all the Kafka consumers that use this configuration</p></td></tr><tr><td><p>Consumer Kerberos</p></td><td><p>Principal</p></td><td><p>Entity for the Apache Kafka system to authenticate</p></td></tr><tr><td></td><td><p>Service name</p></td><td><p>Kerberos principal name associated with Kafka Connector</p></td></tr><tr><td></td><td><p>Kafka configuration file (krb5.conf)</p></td><td><p>File that contains Kerberos configuration information</p></td></tr><tr><td><p>Consumer SASL/OAUTHBEARER</p></td><td><p>Client ID</p></td><td><p>Unique identifier assigned to the OAuth client, facilitating secure authentication and authorization processes</p></td></tr><tr><td></td><td><p>Client Secret</p></td><td><p>Confidential authentication credential assigned to the OAuth client</p></td></tr><tr><td></td><td><p>OAuth Token Endpoint</p></td><td><p>URL where clients can request access tokens from the authentication server</p></td></tr><tr><td><p>Consumer SASL/SCRAM</p></td><td><p>Username</p></td><td><p>Username with which to log in to Kafka</p></td></tr><tr><td></td><td><p>Password</p></td><td><p>Password with which to log in to Kafka</p></td></tr><tr><td></td><td><p>Encryption type</p></td><td><p>Encryption algorithm used by SCRAM</p></td></tr><tr><td><p>Consumer SASL/PLAIN</p></td><td><p>Username</p></td><td><p>Username with which to log in to Kafka</p></td></tr><tr><td></td><td><p>Password</p></td><td><p>Password with which to log in to Kafka</p></td></tr><tr><td><p>Consumer SASL/TOKEN</p></td><td><p>Token ID</p></td><td><p>ID of the token</p></td></tr><tr><td></td><td><p>Token HMAC</p></td><td><p>Token HMAC</p></td></tr><tr><td></td><td><p>Encryption type</p></td><td><p>Encryption algorithm used by SCRAM</p></td></tr></tbody></table>

## Producer Configuration

Create a producer configuration global element:

1.  On the Studio canvas, click **Global Elements**.

2.  Click **Create** and expand **Connector Configuration**.

3.  Select **Apache Kafka Producer configuration** and click **OK**.

4.  In the **Connection** field, select a connection type.

5.  Enter values for the following fields:

<table><colgroup><col> <col> <col></colgroup><tbody><tr><td><p>Connection Type</p></td><td><p>Field Name</p></td><td><p>Description</p></td></tr><tr><td><p>All connection types</p></td><td><p>Bootstrap Server URLs</p></td><td><p>List of host-port pairs that establish the initial connection to the Kafka cluster. Set this value to the <code>bootstrap.servers</code> value you must provide to Kafka producer clients.</p></td></tr><tr><td></td><td><p>Bean reference</p></td><td><p>URLs that the producer can use to connect to the Kafka cluster</p></td></tr><tr><td><p>Producer Kerberos</p></td><td><p>Principal</p></td><td><p>Entity for the Apache Kafka system to authenticate</p></td></tr><tr><td></td><td><p>Service name</p></td><td><p>Kerberos principal name associated with Kafka Connector</p></td></tr><tr><td></td><td><p>Kerberos configuration file (krb5.conf)</p></td><td><p>File that contains Kerberos configuration information</p></td></tr><tr><td><p>Producer SASL/OAUTHBEARER</p></td><td><p>Client ID</p></td><td><p>Unique identifier assigned to the OAuth client, facilitating secure authentication and authorization processes</p></td></tr><tr><td></td><td><p>Client Secret</p></td><td><p>Confidential authentication credential assigned to the OAuth client</p></td></tr><tr><td></td><td><p>OAuth Token Endpoint</p></td><td><p>URL where clients can request access tokens from the authentication server</p></td></tr><tr><td><p>Producer SASL/SCRAM</p></td><td><p>Username</p></td><td><p>Username with which to log in to Kafka</p></td></tr><tr><td></td><td><p>Password</p></td><td><p>Password with which to log in to Kafka</p></td></tr><tr><td></td><td><p>Encryption type</p></td><td><p>Encryption algorithm used by SCRAM</p></td></tr><tr><td><p>Producer SASL/PLAIN</p></td><td><p>Username</p></td><td><p>Username with which to log in to Kafa</p></td></tr><tr><td></td><td><p>Password</p></td><td><p>Password with which to log in to Kafka</p></td></tr><tr><td><p>Producer SASL/TOKEN</p></td><td><p>Token ID</p></td><td><p>ID of the token</p></td></tr><tr><td></td><td><p>Token HMAC</p></td><td><p>Token HMAC</p></td></tr><tr><td></td><td><p>Encryption type</p></td><td><p>Encryption algorithm used by SCRAM</p></td></tr></tbody></table>

## Configure TLS

To enable TLS for your app:

1.  Click the **TLS** tab to configure the truststore and keystore:

    - **Trust Store Configuration**

      - Path  
        Location of the truststore file.

      - Password  
        Password for the truststore file.

      - Type  
        File format of the truststore file.

      - Algorithm  
        Algorithm the truststore uses.

      - Insecure  
        Boolean that determines whether or not to validate the truststore. If set to `true`, no
        validation occurs. The default value is `false`.

    - **Key Store Configuration**

      - Type  
        Optionally specify the file format of the keystore file. The default value is `JKS`.

      - Path  
        Location of the keystore file. This is optional and can be used for two-way authentication
        for the connector.

      - Alias  
        Attribute that indicates the alias of the key to use when the keystore contains many private
        keys. If not defined, the first key in the file is used by default.

      - Key password  
        Key manager password, which is the password for the private key inside the keystore.

      - Password  
        Store password for the keystore file. This is optional and needed only if the **Key Store
        Location** is configured.

      - Algorithm  
        Algorithm used in the keystore.

        ![Kafka consumer configuration window](/mulesoft/current/en-us/kafka-connector/4.14/_images/kafka-tls-studio-config.png)

## Configure the Commit Operation

1.  Drag the **Commit** operation to the Studio canvas.

2.  Configure the **Commit** operation in the **General** tab:

    <table><colgroup><col> <col> <col> <col> <col></colgroup><tbody><tr><td><p>Name</p></td><td><p>Type</p></td><td><p>Description</p></td><td><p>Default Value</p></td><td><p>Required</p></td></tr><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>Consumer commit key</p></td><td><div><div><p>String</p></div></div></td><td><p>The commitKey of the last poll. This operation is valid only when used inside a flow that is using one of the listener sources (<strong>Batch message listener</strong> or <strong>Message listener</strong>) which inserts this value as an attribute in the Mule event.</p></td><td></td><td><p>x</p></td></tr></tbody></table>

    ![Kafka config panel in General tab for consumer config](/mulesoft/current/en-us/kafka-connector/4.14/_images/kafka-commit-studio-config-general.png)

3.  In the **Advanced** tab, configure the reconnection strategy.

## Configure the Consume Operation

1.  Drag the **Consume** operation to the Studio canvas.

2.  Configure the **Consume** operation in the **General** tab:

    <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><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Consumption timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>The number of time units that this operation waits for receiving messages.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Timeout 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>The unit of time for the timeout property.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

    ![Kafka config panel in General tab for consumer config](/mulesoft/current/en-us/kafka-connector/4.14/_images/kafka-consume-studio-config.png)

3.  Configure the following settings in the **Advanced** tab:

    <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><strong>Operation Timeout</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><tr><td><p><strong>Operation Timeout 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></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p>repeatable-in-memory-stream</p></li><li><p>repeatable-file-store-stream</p></li><li><p>non-repeatable-stream</p></li></ul></div></div></td><td><div><div><p>Configure to use repeatable streams.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The name of a variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>An expression that evaluates the operation’s output. The outcome of the evaluation is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p>reconnect</p></li><li><p>reconnect-forever</p></li></ul></div></div></td><td><div><div><p>A retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

## Configure the Publish Operation

1.  Drag the **Publish** operation to the Studio canvas.

2.  Configure the **Publish** operation in the **General** tab:

    <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><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Topic</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The topic to publish to.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Partition</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>(Optional) The topic partition.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Key</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>(Optional) Key for the published message.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Message</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>(Optional) Message content of the message.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Headers</strong></p></td><td><div><div><p>Object</p></div></div></td><td><div><div><p>(Optional) Headers for the message.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

    ![Kafka config panel in General tab for producer config](/mulesoft/current/en-us/kafka-connector/4.14/_images/kafka-publish-studio-config.png)

3.  Configure the following settings in the **Advanced** tab:

    <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><strong>Transactional Action</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>ALWAYS_JOIN</p></li><li><p>JOIN_IF_POSSIBLE</p></li><li><p>NOT_SUPPORTED</p></li></ul></div></div></td><td><div><div><p>The type of joining action that operations can take regarding transactions.</p></div></div></td><td><div><div><p><code>JOIN_IF_POSSIBLE</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The name of a variable to store the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>An expression to evaluate against the operation’s output and store the expression outcome in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p>reconnect</p></li><li><p>reconnect-forever</p></li></ul></div></div></td><td><div><div><p>A retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

## Configure the Bulk Publish Operation

1.  Drag the **Bulk Publish** operation to the Studio canvas.

2.  Configure the **Bulk Publish** operation in the **General** tab:

    <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><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Messages</strong></p></td><td><div><div><p>Array of KafkaMessage</p></div></div></td><td><div><div><p>The list of messages to publish.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr></tbody></table>

3.  Configure the following settings in the **Advanced** tab:

    <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><strong>Transactional Action</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>ALWAYS_JOIN</p></li><li><p>JOIN_IF_POSSIBLE</p></li><li><p>NOT_SUPPORTED</p></li></ul></div></div></td><td><div><div><p>The type of joining action that operations can take regarding transactions.</p></div></div></td><td><div><div><p><code>JOIN_IF_POSSIBLE</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>The name of a variable to store the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>An expression to evaluate against the operation’s output and store the expression outcome in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p>reconnect</p></li><li><p>reconnect-forever</p></li></ul></div></div></td><td><div><div><p>A retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

For an example that builds the required `KafkaMessage` array and publishes multiple messages, see
[Publish Multiple Messages with Bulk Publish](https://docs.mulesoft.com/kafka-connector/4.14/kafka-connector-bulk-publish-example).

## Configure the Seek Operation

1.  Drag the **Seek** operation to the Studio canvas.

2.  Configure the **Seek** operation in the **General** tab:

    <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><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Topic</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the topic on which to perform the seek operation.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Partition</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Partition number for which to modify the offset.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Offset</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Offset value to commit for the configured partition.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr></tbody></table>

3.  Configure the following settings in the **Advanced** tab:

    <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><strong>Operation Timeout</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><tr><td><p><strong>Operation Timeout 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></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>reconnect</p></li><li><p>reconnect-forever</p></li></ul></div></div></td><td><div><div><p>A retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

## Configure an Input Source

Configure an input source for the connector, such as the **Message Consumer** operation:

<table><colgroup><col> <col></colgroup><thead><tr><th>Name</th><th>Description</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>The name of the configuration to use.</p></div></div></td></tr><tr><td><p><strong>Topic</strong></p></td><td><div><div><p>Name of the topic from which to consume messages.</p></div></div></td></tr><tr><td><p><strong>Primary Node Only</strong></p></td><td><div><div><p>Whether to execute this source on only the primary node when running in a cluster.</p></div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p>repeatable-in-memory-stream</p></li><li><p>repeatable-file-store-stream</p></li><li><p>non-repeatable-stream</p></li></ul></div><div><p>Configure to use repeatable streams.</p></div></div></td></tr><tr><td><p><strong>Redelivery Policy</strong></p></td><td><div><div><p>Defines a policy for processing the redelivery of the same message.</p></div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><p>A retry strategy in case of connectivity errors.</p></div><div><ul><li><p>reconnect</p></li><li><p>reconnect-forever</p></li></ul></div></div></td></tr></tbody></table>

You can also use the **Batch Message Listener** operation as an input source in Apache Kafka
Connector:

<table><colgroup><col> <col></colgroup><thead><tr><th>Name</th><th>Description</th></tr></thead><tbody><tr><td><p><strong>Connector Configuration</strong></p></td><td><div><div><p>The name of the configuration to use.</p></div></div></td></tr><tr><td><p><strong>Poll timeout</strong></p></td><td><div><div><p>The amount of time to block.</p></div></div></td></tr><tr><td><p><strong>Poll timeout time unit</strong></p></td><td><div><div><p>The time unit for the polling timeout. This combines with poll timeout to define the total timeout for the polling.</p></div></div></td></tr><tr><td><p><strong>Acknowledgment mode</strong></p></td><td><div><div><p>Declares the supported acknowledgment mode type.</p></div></div></td></tr><tr><td><p><strong>Amount of parallel consumers</strong></p></td><td><div><div><p>Declares how many consumers to use in parallel.</p></div></div></td></tr><tr><td><p><strong>Primary Node Only</strong></p></td><td><div><div><p>Whether this source should be executed only on the primary node when running in a cluster.</p></div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><p>Define the streaming strategy.</p></div><div><ul><li><p>repeatable-in-memory-stream</p></li><li><p>repeatable-file-store-stream</p></li><li><p>non-repeatable-stream</p></li></ul></div></div></td></tr><tr><td><p><strong>Redelivery Policy</strong></p></td><td><div><div><p>Defines a policy for processing the redelivery of the same message.</p></div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><p>A retry strategy in case of connectivity errors.</p></div><div><ul><li><p>reconnect</p></li><li><p>reconnect-forever</p></li></ul></div></div></td></tr></tbody></table>

## See Also

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

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