2 Home

gitea_admin edited this page 2026-03-11 14:39:38 +00:00

Unescape Escape

Table of Contents

• Pulsar Sink
• Metadata
• Properties
• Dependencies

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

Pulsar Sink

Send documents to Pulsar.

Metadata

Property	Value
Type	sink
Group	Pulsar
Namespace	Messaging
Support Level	Stable
Provider	Apache Software Foundation

Properties

Name	Type	Required	Default	Description
topic	string	✓		The topic name or regexp
tenant	string	✓		The Tenant Name
topicType	string	✓		The topic type.
namespaceName	string	✓		The Pulsar Namespace Name
serviceUrl	string	✓		The Pulsar Service URL to point while creating the client from URI.
authenticationClass	string			The Authentication FQCN to be used while creating the client from URI.
authenticationParams	string			The Authentication Parameters to be used while creating the client from URI.
batchingEnabled	boolean		true	Control whether automatic batching of messages is enabled for the producer.
batchingMaxMessages	integer		1000	The maximum size to batch messages.
batchingMaxPublishDelayMicros	integer		1000	The maximum time period within which the messages sent will be batched if batchingEnabled is true.
blockIfQueueFull	boolean		false	Whether to block the producing thread if pending messages queue is full or to throw a ProducerQueueIsFullError.
compressionType	string		NONE	Compression type to use.
initialSequenceId	integer		-1	The first message published will have a sequence Id of initialSequenceId 1.
lazyStartProducer	boolean		false	Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel’s routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.
maxPendingMessages	integer		1000	Size of the pending massages queue. When the queue is full, by default, any further sends will fail unless blockIfQueueFull=true.
maxPendingMessagesAcrossPartitions	integer		50000	The maximum number of pending messages for partitioned topics. The maxPendingMessages value will be reduced if (number of partitions maxPendingMessages) exceeds this value. Partitioned topics have a pending message queue for each partition.
messageRoutingMode	string		RoundRobinPartition	Message Routing Mode to use.
producerName	string			Name of the producer. If unset, lets Pulsar select a unique identifier.
sendTimeoutMs	integer		30000	Send timeout in milliseconds.

Dependencies

• camel:pulsar
• camel:kamelet
• camel:core