Name | Type | Description |
---|---|---|
Pulsar brokers | String | A list of host/port pairs to use for establishing the initial connection to the Pulsar cluster. |
Use TLS | Boolean | Whether to use TLS encryption on the connection. |
Topic type | String | It identifies type of topic. Pulsar supports two kind of topics: persistent and non-persistent. In persistent topic, all messages are durably persisted on disk (that means on multiple disks unless the broker is standalone), whereas non-persistent topic does not persist message into storage disk. |
Topic tenant | String | The topic tenant within the instance. Tenants are essential to multi-tenancy in Pulsar, and spread across clusters. |
Topic namespace | String | The administrative unit of the topic, which acts as a grouping mechanism for related topics. Most topic configuration is performed at the namespace level. Each tenant has one or multiple namespaces. |
Topic pattern | String | Topic pattern in which the records will be sent. You can use patterns like '{namespace}' and/or '{stream}' to send the message to a specific topic based on these values. Notice that the topic name will be transformed to a standard naming convention. |
Test topic | String | Topic to test if Airbyte can produce messages. |
Producer name | String | Name for the producer. If not filled, the system will generate a globally unique name which can be accessed with. |
Sync producer | Boolean | Wait synchronously until the record has been sent to Pulsar. |
Compression type | String | Compression type for the producer. |
Message send timeout | Integer | If a message is not acknowledged by a server before the send-timeout expires, an error occurs (in ms). |
Max pending messages | Integer | The maximum size of a queue holding pending messages. |
Max pending messages across partitions | Integer | The maximum number of pending messages across partitions. |
Enable batching | Boolean | Control whether automatic batching of messages is enabled for the producer. |
Batching max messages | Integer | Maximum number of messages permitted in a batch. |
Batching max publish delay | Integer | Time period in milliseconds within which the messages sent will be batched. |
Block if queue is full | Boolean | If the send operation should block when the outgoing message queue is full. |