Stream Processing
Scalable Stream Processing
★ 4.6
Event-Driven API Gateway
★ 3.7
pip install pysparkN/A — Java-based gatewaypip install pysparkN/A — Java-based gatewayPython data engineers use Spark Structured Streaming via PySpark to process high-volume Kafka streams at scale. A streaming job reads a Kafka topic as a DataFrame, applies transformations (filtering, aggregations, joins with static data), and writes results continuously to Delta Lake or a database — using the same PySpark syntax as batch jobs.
Python data engineers use Zilla to give non-Kafka consumers HTTP-based access to Kafka data — a Python REST client can read from or write to a Kafka topic without the Kafka client library. This simplifies event-driven microservice architectures where lightweight Python services need to participate in a Kafka-based pipeline without managing consumer group offsets.
Individual Tool Pages