Get started with Pulsar

Prerequisites

You need the following:

• Git
• Python >3.7
• pip

Build the project

Clone the example project and use pip to build it.

Use

The example script takes as input parameter the broker binary endpoint of Pulsar, the name of the topic to read from and your token to have the authorization to write on the topic.

For that reason, you will need to specify in Graal the following parameters "--pulsar_broker", "--pulsar_token", "--pulsar_topic"

For producer we used Pulsar Python client instead of Spark Python client.