Add support for multiple sources other than kafka for Firehose

[sravankorumilli]

Acceptance Criteria

1. Kafka, BQ both should be sources
2. Come up with the core design with which the solution will work.
3. Sinks are Kafka & Postgres