pulsar

Found an error? Have a suggestion?Edit this page on GitHub

Pulsar Bindings

This document defines how to describe Apache Pulsar specific information with AsyncAPI.

Version

Current version is 0.1.0.

Server Binding Object

This object contains information about the server representation in Pulsar.

Fixed Fields
Field NameTypeRequiredDescriptionDefault value
tenantStringNoThe pulsar tenant. If omitted, "public" MUST be assumed.public
bindingVersionStringNoThe version of this binding. If omitted, "latest" MUST be assumed.latest
Example
1servers:
2  production:
3    bindings:
4      pulsar:
5        tenant: contoso
6        bindingVersion: '0.1.0'

Channel Binding Object

This object contains information about the channel representation in Pulsar

Fixed Fields
Field NameTypeRequiredDescriptionDefault value
namespaceStringYesThe namespace the channel is associated with.N/A
persistenceStringYesPersistence of the topic in Pulsar. It MUST be either persistent or non-persistent.N/A
compactionIntegerNoTopic compaction threshold given in Megabytes.N/A
geo-replicationString[]NoA list of clusters the topic is replicated to.N/A
retentionRetention Definition ObjectNoTopic retention policy.N/A
ttlIntegerNoMessage time-to-live in seconds.N/A
deduplicationBooleanNoMessage deduplication. When true, it ensures that each message produced on Pulsar topics is persisted to disk only once.N/A
bindingVersionStringNoThe version of this binding. If omitted, "latest" MUST be assumed.latest

Retention Definition Object

The Retention Definition Object is used to describe the Pulsar Retention policy.

Field NameTypeRequiredDescriptionDefault value
timeIntegerNoTime given in Minutes.0
sizeIntegerNoSize given in MegaBytes.0
Example
1channels:
2  user-signedup:
3    bindings:
4      pulsar:
5        namespace: 'staging'
6        persistence: 'persistent'
7        compaction: 1000
8        geo-replication:
9          - 'us-east1'
10          - 'us-west1'
11        retention:
12          time: 7
13          size: 1000
14        ttl: 360
15        deduplication: false
16        bindingVersion: '0.1.0'

Operation binding fields

This object MUST NOT contain any properties. Its name is reserved for future use.

Message binding fields

This object MUST NOT contain any properties. Its name is reserved for future use.

Was this helpful?
Help us improve the docs by adding your contribution.
OR
Github:AsyncAPICreate Issue on GitHub