Skip to content

Latest commit

 

History

History
12 lines (9 loc) · 417 Bytes

README.md

File metadata and controls

12 lines (9 loc) · 417 Bytes

Pulsar-UniversalSink

Consumes from a Pulsar Topic and inserts into a destination C* table using Startgate REST API.

Settings

The Auth.py file should be modified to inlcude endpoints information. The Schema.py file should be modified to specify the structure of the table.

Run with Python

Clone this repo, install Python 3.7+ and install run the following commands pip install pulsar pip install requests