Pulsar Functions are lightweight compute processes that can perform the following operations:
Consume messages from one or more Pulsar topics.
Apply a user-supplied processing logic to each message.
Publish the results of the computation to another topic.
Pulsar Functions are computing infrastructure of Pulsar messaging system. With Pulsar Functions, you can create complex processing logic without deploying a separate neighboring system, such as Apache Storm, Apache Heron, or Apache Flink.
Pulsar Functions can be described as Lambda-style functions that are specifically designed to use Pulsar as a message bus.
Pulsar Functions provide a wide range of functionality, and the core programming model is simple. Functions receive messages from one or more input topics. After a message is received, the function completes the following tasks.
Apply a processing logic to the input messages and write output messages to an output topic in Pulsar.
Write logs to a log topic, which is mainly used for debugging issues.
Pulsar Functions provide three different messaging semantics that you can apply to any function.
|At-most-once||The message sent to the function is processed at most once. Therefore, there is a chance that the message is not processed.|
|At-least-once||The message sent to the function is processed more than once. Therefore, there is a chance that the message is processed redundantly.|
|Effectively-once||The message sent to the function is processed only once and has one output associated with it.|
Currently, you can write Pulsar Functions in Java, Python, and Go. For details, refer to functions examples.
Pulsar Functions APIs
Pulsar Functions APIs are used to manage Pulsar Functions. For details, see Functions APIs.