Module pulsar

Modules

• opaque_type 🔒

Structs

• PulsarConfig
• PulsarPayloadWriter 🔒
• PulsarPropertiesProducer
• PulsarSink
• PulsarSinkWriter

Constants

• PULSAR_SEND_FUTURE_BUFFER_MAX_SIZE 🔒
  The delivery buffer queue size When the SendFuture the current send_future_buffer is buffering is greater than this size, then enforcing commit once
• PULSAR_SINK

Functions

• _default_batch_byte_size 🔒
• _default_batch_size 🔒
• _default_max_retries 🔒
• _default_retry_backoff 🔒
• build_pulsar_producer 🔒
• pulsar_to_sink_err 🔒

Type Aliases

• PulsarDeliveryFuture