Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 10 additions & 5 deletions docs/resources/sink.md
Original file line number Diff line number Diff line change
Expand Up @@ -57,11 +57,16 @@ Manages Pulsar IO sinks through the Functions Worker API.

Required:

- `is_regex_pattern` (Boolean)
- `key` (String)
- `receiver_queue_size` (Number)
- `schema_type` (String)
- `serde_class_name` (String)
- `key` (String) The input topic that this consumer configuration applies to.

Optional:

- `consumer_properties` (Map of String) Consumer properties key/values for this topic.
- `is_regex_pattern` (Boolean) Whether the topic is a regex pattern matching multiple topics. Pulsar rejects a change to this on an existing sink.
- `pool_messages` (Boolean) Whether the consumer pools messages for this topic.
- `receiver_queue_size` (Number) The consumer receiver queue size for this topic. When omitted, the provider sends 1000, which buffers up to that many messages per sink instance. Set to 0 to disable prefetch.
- `schema_type` (String) The schema type of this topic, either a builtin schema type such as `avro` or a Schema implementation class name. Cannot be set together with `serde_class_name`.
- `serde_class_name` (String) The serde class name of this topic. Cannot be set together with `schema_type`.

## Import

Expand Down
Loading
Loading