Kesque Supports Pulsar Functions

Pulsar Functions are lightweight compute instances that perform work on each message published to a topic. They can be used to clean, enrich, and route data as it passes through an Apache Pulsar cluster. Kesque now supports Pulsar functions on all its plans, from the Free plan to the Private and Managed Cluster plans.

Integrated

Pulsar Functions are integrated into the Apache Pulsar cluster. There is no need for special libraries or external systems. You write your code in Python or Java, upload the function, and then link it to a topic. For each message published to that topic, your custom code will be run. If, for example, the message contains strings, you can apply custom logic to that string an then input a modified to an output topic. That output topic can serve as the input topic for another Pulsar function, so you can build a pipeline of functions that process each message.

Simple

You can create a Pulsar Function with only a few lines of code. Here is a Pulsar Function written in Python that adds an exclamation mark to the end of a string:

def process(input):
    return "{}!".format(input)

That’s it. Upload those two lines of code and you have a working Pulsar Function.

Serverless Streaming

In addition to publishing to the output topic, you can publish to any arbitrary topic. You can configure your functions with key-value pairs, generate logs, and even update counters or other stateful variables.

With Pulsar Functions, Kesque allows you to build powerful serverless streaming applications. The code you write executes within our secure and fully managed service. You don’t have to maintain library dependencies or servers. Just write the code, upload it, and watch it run.

Get Started With Pulsar Functions

You can get started with Pulsar Functions right now. With the Free plan, you get one function to try out. If you need more functions, you can move up to our Starter plan, which gives you 10 functions to work with. The Starter plan has a 30-day free trial.

You can get more information on using Pulsar Function on Kesque in our docs.