Pulsar Source

Receive data from Pulsar topics.

Metadata

Property	Value
Type	source
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.
`consumerNamePrefix`	string		`cons`	Prefix to add to consumer names when a SHARED or FAILOVER subscription is used
`consumerQueueSize`	integer		`10`	Size of the consumer queue
`deadLetterTopic`	integer			Name of the topic where the messages which fail maxRedeliverCount times will be sent. Note: if not set, default topic name will be topicName-subscriptionName-DLQ.
`maxRedeliverCount`	integer			Maximum number of times that a message will be redelivered before being sent to the dead letter queue. If this value is not set, no Dead Letter Policy will be created.
`negativeAckRedeliveryDelayMicros`	integer		`60000000`	Set the negative acknowledgement delay.
`messageListener`	boolean		`true`	Whether to use the messageListener interface, or to receive messages using a separate thread pool.
`numberOfConsumers`	integer		`1`	Number of consumers.
`numberOfConsumerThreads`	integer		`1`	Number of threads to receive and handle messages when using a separate thread pool.
`readCompacted`	boolean		`false`	Enable compacted topic reading.
`subscriptionInitialPosition`	string		`LATEST`	Control the initial position in the topic of a newly created subscription. Default is latest message.
`subscriptionName`	string		`subs`	Name of the subscription to use.
`subscriptionTopicsMode`	string		`PersistentOnly`	Determines to which topics this consumer should be subscribed to - Persistent, Non-Persistent, or both. Only used with pattern subscriptions.
`subscriptionType`	string		`EXCLUSIVE`	Type of the subscription.
`topicsPattern`	boolean		`false`	Whether the topic is a pattern (regular expression) that allows the consumer to subscribe to all matching topics in the namespace.

Dependencies

camel:pulsar
camel:kamelet
camel:core