Please describe the end goal of this project This is a meta issue for all work related to the pull-based ingestion to ingest from streaming sources like Kafka and Kinesis directly. Supporting Refer...