Labs | Factor House Docs

Overview

Overview of Factor House Local labs

Produce and consume Avro Kafka messages using Python clients and Schema Registry

Manage Kafka Connect source and sink connectors via Kpow UI and API

Build a Kafka Streams app for real-time supplier stats with live topology view

Aggregate supplier stats from Kafka orders using Flink SQL

Implement a Flink DataStream job for real-time analytics on Kafka orders

Write Kafka order records as Parquet files to MinIO using Flink SQL

Ingest Kafka order records into an Iceberg table via Flink SQL

Build a Kafka-to-Iceberg pipeline using Flink Table API

Stream Kafka order data into Iceberg using Kafka Connect

Deliver Kafka order data to Iceberg with a PySpark Structured Streaming

Serve real-time supplier stats via Flink SQL Gateway REST API

Stream Kafka orders into Pinot and run real-time analytics via Python client