Apache Kafka Connector 4.10 Reference | MuleSoft Documentation
### Consumer Context
Type for the consumer context.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Consumer Commit Key** |  Consumer commit key.  
### CRL File
Specifies the location of the certification revocation list (CRL) file.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Path to the CRL file.  
### Custom OCSP Responder
Configures a custom OCSP responder for certification revocation checks.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
URL of the OCSP responder.  
**Cert Alias** |  Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore.  
### Expiration Policy
Configures an expiration policy strategy.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Max Idle Time** |  Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration.  
Enumeration, one of:
  * NANOSECONDS
  * MICROSECONDS
  * MILLISECONDS
  * SECONDS
  * MINUTES
  * HOURS

|  Time unit for the **Max Idle Time** field.  
### Kafka Message
Represents a Kafka message.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Attributes** |  Kafka Message Attributes |  Attributes associated with the Kafka message.  
Payload of the Kafka message, represented as an InputStream.  
### Kafka Message Attributes
Represents the attributes of a Kafka message.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Headers of the Kafka message, represented as a map in which the key is a string and the value is an InputStream.  
Key of the Kafka message, represented as an InputStream.  
Partition of the topic where the Kafka message is sent.  
Topic to which the Kafka message belongs to.  
### Kafka Message Metadata
Metadata of the Kafka message.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Offset of the message.  
Partition of the message.  
**Serialized Key Size** |  Serialized key size of the message.  
**Serialized Value Size** |  Serialized value size of the message.  
Timestamp of the message.  
Topic of the message.  
### Kafka Record Attributes
Attributes of the Kafka record.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Consumer Commit Key** |  Consumer commit key.  
**Creation Timestamp** |  Timestamp of record creation.  
Map of HTTP headers in the message.  
Keys of the record.  
**Leader Epoch** |  Leader epoch of the record.  
**Log Append Timestamp** |  Log append timestamp of the record.  
Offset of the record.  
Partition of the record.  
**Serialized Key Size** |  Serialized key size of the record.  
**Serialized Value Size** |  Serialized value size of the record.  
Topic of the record.  
### Keystore
Configures the keystore for the TLS protocol. The keystore you generate contains a private key and a public certificate.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Path to the keystore. Mule resolves the path relative to the current classpath and file system.  
Type of keystore.  
Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file.  
**Key Password** |  Password used to protect the private key.  
Password used to protect the keystore.  
Encryption algorithm that the keystore uses.  
### Proxy Config Params
Configures the proxy configuration parameters.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Hostname or IP address of the proxy server.  
Port of the proxy server.  
Username to authenticate against the proxy server.  
Password to authenticate against the proxy server.  
### Reconnect
Configures a standard reconnection strategy, which specifies how often to reconnect and how many reconnection attempts the connector source or operation can make.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
How often to attempt to reconnect, in milliseconds.  
If `false`, the reconnection strategy runs in a separate, non-blocking thread.  
How many reconnection attempts the Mule app can make.  
### Reconnect Forever
Configures a forever reconnection strategy by which the connector source or operation attempts to reconnect at a specified frequency for as long as the Mule app runs.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
How often to attempt to reconnect, in milliseconds.  
If `false`, the reconnection strategy runs in a separate, non-blocking thread.  
### Reconnection
Configures a reconnection strategy for an operation.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Fails Deployment** |  What to do if, when an app is deployed, a connectivity test does not pass after exhausting the associated reconnection strategy:
  * `true` Allow the deployment to fail.
  * `false` Ignore the results of the connectivity test.

  
**Reconnection Strategy** | 
  *   * Reconnect Forever

|  Reconnection strategy to use.  
### Record
Type for records.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Attributes** |  Kafka Record Attributes |  Kafka record attributes.  
Payload for the record.  
### Redelivery Policy
Configures the redelivery policy for executing requests that generate errors. You can add a redelivery policy to any source in a flow.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Max Redelivery Count** |  Maximum number of times that a redelivered request can be processed unsuccessfully before returning a REDELIVERY_EXHAUSTED error.  
**Use Secure Hash** |  If `true`, Mule uses a secure hash algorithm to identify a redelivered message.  
**Message Digest Algorithm** |  Secure hashing algorithm to use if the **Use Secure Hash** field is `true`. If the payload of the message is a Java object, Mule ignores this value and returns the value that the payload’s `hashCode()` returned.  
**Id Expression** |  Defines one or more expressions to use to determine when a message has been redelivered. This property may only be set if **Use Secure Hash** is `false`.  
**Object Store** |  ObjectStore |  Configures the object store that stores the redelivery counter for each message.  
### Repeatable File Store Stream
Configures the repeatable file-store streaming strategy by which Mule keeps a portion of the stream content in memory. If the stream content is larger than the configured buffer size, Mule backs up the buffer’s content to disk and then clears the memory.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**In Memory Size** |  Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:
  * Configure a larger buffer size to avoid the number of times Mule needs to write the buffer on disk. This increases performance, but it also limits the number of concurrent requests your application can process, because it requires additional memory.
  * Configure a smaller buffer size to decrease memory load at the expense of response time.

  
**Buffer Unit** |  Enumeration, one of: |  Unit for the **In Memory Size** field.  
### Repeatable In Memory Stream
Configures the in-memory streaming strategy by which the request fails if the data exceeds the MAX buffer size. Always run performance tests to find the optimal buffer size for your specific use case.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Initial Buffer Size** |  Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by **Buffer Size Increment** , with an upper limit of **Max In Memory Size value**.  
**Buffer Size Increment** |  Amount by which the buffer size expands if it exceeds its initial size. Setting a value of `0` or lower specifies that the buffer can’t expand.  
**Max Buffer Size** |  Maximum amount of memory to use. If more than that is used then a STREAM_MAXIMUM_SIZE_EXCEEDED error is raised. A value lower than or equal to zero means no limit.  
**Buffer Unit** |  Enumeration, one of: |  Unit for the **Initial Buffer Size** , **Buffer Size Increment** , and **Buffer Unit** fields.  
### Standard Revocation Check
Configures standard revocation checks for TLS certificates.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Only End Entities** |  Which elements to verify in the certificate chain:
  * `true` Verify only the last element in the certificate chain.
  * `false` Verify all elements in the certificate chain.

  
**Prefer Crls** |  How to check certificate validity:
  * `true` Check the Certification Revocation List (CRL) for certificate validity.
  * `false` Use the Online Certificate Status Protocol (OCSP) to check certificate validity.
**Prefer Crls** |  How to check certificate validity:
  * `true` Check the Certification Revocation List (CRL) for certificate validity.
  * `false` Use the Online Certificate Status Protocol (OCSP) to check certificate validity.

  
**No Fallback** |  Whether to use the secondary method to check certificate validity:
  * `true` Use the method that wasn’t specified in the **Prefer Crls** field (the secondary method) to check certificate validity.
  * `false` Do not use the secondary method to check certificate validity.

  
What to do if the revocation server can’t be reached or is busy:
  * `true` Avoid verification failure.
  * `false` Allow the verification to fail.

  
### Tcp Client Socket Params
Configures the TCP client socket parameters.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Send Buffer Size** |  Size of the buffer (in bytes) used when sending data, set on the socket itself.  
**Receive Buffer Size** |  Buffer size.  
**Client Timeout** |  Sets the `SO_TIMEOUT` value on sockets. Indicates the amount of time (in milliseconds) that the socket waits in a blocking operation before failing. A value of 0 (the default) means waiting indefinitely.  
**Send Tcp No Delay** |  If set, data is sent immediately rather than being collected for efficiency, prioritizing latency over network traffic reduction. Despite the socket default being false, this option defaults to true because reducing network traffic is generally not a major concern.  
Sets the `SO_LINGER` value in milliseconds. This determines how long the socket remains open to ensure all remaining data is transmitted correctly before closing.  
**Keep Alive** |  Enables the `SO_KEEPALIVE` behavior on open sockets. This option periodically checks idle socket connections and closes them if they become unavailable. It is used by server sockets to control whether connections are kept alive before being recycled.  
**Connection Timeout** |  How long the connector waits before timing out when establishing a connection to the remote service.  
Configures TLS to provide secure communications for the Mule app.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
**Enabled Protocols** |  Comma-separated list of protocols enabled for this context.  
**Enabled Cipher Suites** |  Comma-separated list of cipher suites enabled for this context.  
**Trust Store** |  Configures the TLS truststore.  
Configures the TLS keystore.  
**Revocation Check** | 
  * Standard Revocation Check
  * Custom OCSP Responder

|  Configures a revocation checking mechanism.  
### Topic Partition
Type for topic partition.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Topic name.  
Number of partitions.  
### Truststore
Configures the truststore for TLS.
Field | Type | Description | Default Value | Required  
---|---|---|---|---  
Path to the truststore. Mule resolves the path relative to the current classpath and file system.  
Password used to protect the truststore.  
Type of truststore.  
Encryption algorithm that the truststore uses.  
If `true`, Mule stops performing certificate validations. Setting this to `true` can make connections vulnerable to attacks.  
## See Also
  * Introduction to Anypoint Connectors
  * MuleSoft Help Center