Build streaming pipelines and always-fresh analytics — Kafka for events, Flink and Bytewax for processing, Materialize and Tinybird for incremental SQL and APIs
6 skills · Works with Claude Code, Codex, Cursor & more
Build event-driven architectures with Apache Kafka. Generates producers, consumers, stream processors, schema definitions with Avro/Protobuf, and Kafka Connect configurations for real-time data pipelines.
claude install-skill nicholasoxford/claude-code-skills/kafka Build stateful stream processing with Apache Flink. Generates DataStream and Table API jobs, SQL pipelines, watermark strategies, exactly-once sinks, and Kubernetes Operator deployments.
claude install-skill community/flink-streaming Build Python-native stream processing pipelines with Bytewax. Generates dataflows, stateful operators, windowing logic, Kafka/Redis connectors, and Kubernetes deployments — no JVM required.
claude install-skill community/bytewax-streams Write streaming SQL with Materialize for sub-second incremental views over Kafka, Postgres CDC, and webhooks. Generates sources, materialized views, sinks, and subscribe queries for real-time apps.
claude install-skill community/materialize-streaming Ship real-time analytics APIs with Tinybird. Generates data sources, materialized views, pipes, and published API endpoints powered by ClickHouse — for in-product analytics, monitoring, and personalization.
claude install-skill community/tinybird-realtime Build durable, fault-tolerant workflows with Temporal. Generates workflow and activity definitions in TypeScript or Go, configures retry policies, implements saga patterns, and handles long-running business processes.
claude install-skill nicholasoxford/claude-code-skills/temporal Build AI-powered applications with RAG, multi-agent systems, prompt engineering, and MCP integrations
Modern warehouse-native data engineering — dbt for transformations, Dagster for orchestration, DuckDB and Polars for fast local analytics, plus pipeline and SQL fundamentals
End-to-end deployment, monitoring, and infrastructure skills for shipping and operating production systems