Real-time Input Streams

1. Under the Data option of an API instance, you can find Streaming. Here, you can retrieve the data from the Apache Pulsar cluster.

Pulsar is a multi-tenant, high-performance solution for server-to-server messaging. Using Pulsar, the publisher publishes the messages to different topics, and then the messages are broadcasted to all subscriptions.

Hypi acts as a subscriber and provides the user interface to stream messages from topics.

2. To start streaming the messages, click on +New Stream

3. Enter the details of the pulsar messaging source. Provide the source name or topic name. Choose the account created in the instance for which message streaming must be started. From the dropdown, choose an in-built function. This function will process the input stream and transfer the data in the instance.

4. By default, input streaming starts running. But you can toggle the Not Running button to keep the status Not Running. You may keep the status Non-persistent or persistent as per the settings provided in the Pulsar Cluster.

5. Click on Enable credentials to provide the Pulsar service URL settings. Enter Host, port, and token (if applicable). Click on Create Streaming source to create the Pulsar Messaging source.

6. The Pulsar Source gets added. You may edit the source information or delete the source.

7. You may start or stop running the stream or keep the messages Persistent or Non- persistent.