⚠️ DEPRECATED: Typed connector configuration models are deprecated and will be removed in v1.1.0. Pass configuration as a plain dict with a required 'destinationType' key instead..
| Field | Type | Required | Description |
|---|---|---|---|
batching_delay_threshold |
Optional[int] | ➖ | Number of ms before the buffer is flushed |
batching_element_count_threshold |
Optional[int] | ➖ | Number of messages before the buffer is flushed |
batching_enabled |
Optional[bool] | ➖ | If TRUE messages will be buffered instead of sending them one by one |
batching_request_bytes_threshold |
Optional[int] | ➖ | Number of bytes before the buffer is flushed |
credentials_json |
str | ✔️ | The contents of the JSON service account key. Check out the docs if you need help generating this key. |
destination_type |
models.Pubsub | ✔️ | N/A |
ordering_enabled |
Optional[bool] | ➖ | If TRUE PubSub publisher will have message ordering enabled. Every message will have an ordering key of stream |
project_id |
str | ✔️ | The GCP project ID for the project containing the target PubSub. |
topic_id |
str | ✔️ | The PubSub topic ID in the given GCP project ID. |