Announcing: The Pulsar PMC Published The 2020 Apache Pulsar User Survey Report!

Overview
Get started
Install and upgrade
Configure
Secure
Manage and monitor
Connect
Process
Overview
Pulsar Flink Connector
Pulsar Spark Connector
Pulsar Functions
Release notes

Pulsar Functions

StreamNative Platform uses Pulsar Functions to:

  • 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.

Goal

With Pulsar Functions, you can create complex processing logic without deploying a separate neighboring system (such as Apache Storm, Apache Heron, Apache Flink). Pulsar Functions are computing infrastructure of Pulsar messaging system. The core goal is tied to a series of other goals:

  • Developer productivity (language-native vs Pulsar Functions SDK functions)
  • Easy troubleshooting
  • Operational simplicity (no need for an external processing system)

Inspiration

Pulsar Functions are inspired by (and take cues from) several systems and paradigms:

Pulsar Functions can be described as Lambda-style functions that are specifically designed to use Pulsar as a message bus.

Reference

Pulsar Functions guides are shown as below: