Consumes from a Pulsar Topic and inserts into a destination C* table using Startgate REST API.
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.
Clone this repo, install Python 3.7+ and install run the following commands
pip install pulsar
pip install requests