Kafka
Connection Settings
Broker URIs
Security Type
Security type used for Kafka client connection.
-
Plaintext: No security is used.
-
SSL: Enables SSL for the client connection.
- Truststore CA Certificate: The CA certificate used for the client connection.
- Keystore Client Keypair: The client keypair used to encrypt/decrypt the client communication.
Input Settings
Topic
Specifies the topic the input subscribes to.
Group
Specifies the group id the input joins when subscribing.
Initial Offset
Specifies where to start consuming records when there is no initial offset in Kafka or the current offset is no longer available on the server.
Key Format, Value Format
Specifies the expected key or value format for topic updates.
| Type | Description |
|---|---|
| Any | The payload can be JSON, String, or Binary |
| JSON | The payload is deserialized as JSON. Non-JSON payloads are ignored. |
| String (UTF-8) | The payload is treated as a string. |
| Binary | The payload is treated as a byte array. |
Max Messages
Specifies the maximum number of records per read. The read value is an array with length up to Max Messages the configured maximum greater than 1 with maximum size of Max Messages.
Include Metadata
Include metadata with the read, including the topic, partition, offset, timestamp, headers, and key.
Output Settings
Topic
Specifies the topic that the value is written to.
Key
Specifies the key that the value is mapped to under a topic.