HTTPSource

[sarahwooders]

Add built-in HTTPSource that extends the Source object. The goal is to allow streaming data sources without requiring the user to install kafka (currently required by the KafkaSource).

Recommended task breakdown (subject to change):

• Specify endpoint that the source listens to

• Add a .listen(self) endpoint to receive post requests at the endpoint

• Update the .next(self) function to return records that have been received form the endpoint

• Write test script which posts events from the client side and ensures the events are received by the HTTPSource and passed through ralf.