ldaniels528 / broadway-v1 Star 3 Code Issues Pull requests Broadway is a distributed actor-based processing server optimized for high-speed data/file ingestion nodejs json node scala csv kafka broadway actors avro etl narrative flow-control ingestion etl-framework avro-format Updated Mar 29, 2016 Scala
invadergir / turbocow Star 0 Code Issues Pull requests spark ingestion transformation Updated Mar 24, 2017 Scala
ldaniels528 / transgress Star 1 Code Issues Pull requests A distributed processing/orchestration server and ETL for NodeJS nodejs tsv json node scala csv etl scalajs ingestion etl-framework scalajs-io Updated Apr 22, 2017 Scala
phdata / pipeforge Star 6 Code Issues Pull requests scala hadoop ingestion pipewrench Updated Dec 4, 2018 Scala
Azure / azure-event-hubs-spark Star 238 Code Issues Pull requests Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs microsoft streaming real-time scala kafka spark apache-spark stream connector azure bigdata apache spark-streaming eventhubs ingestion continuous event-hubs databricks structured-streaming Updated Feb 14, 2025 Scala
AbsaOSS / hyperdrive Star 46 Code Issues Pull requests Extensible streaming ingestion pipeline on top of Apache Spark streaming framework kafka spark apache-spark pipeline ingestion streaming-etl spark-structured-streaming Updated Jul 17, 2025 Scala