3 projects
water-healer
Extension of Kafka Streamz to update consumer offset for successful sink
ondemand-dask
Dask cluster on demand and automatically delete itself after expired. Only support GCP for now.
dynamic-singer
Python API, Dynamic source, Dynamic target, N targets, Prometheus exporter, realtime transformation for Singer ETL