# data-pipeline

> Data pipeline development with Kafka, stream processing, SSE integration, and Wikipedia EventStreams. Use when working on: (1) Kafka consumer and producer implementation, (2) Stream processing with ZIO-streams, (3) Server-Sent Events (SSE) integration, (4) Wikipedia EventStreams API consumption, (5) Data transformation and enrichment, (6) Backpressure and flow control, (7) Stream error handling and recovery, (8) Message serialization and deserialization, or (9) Pipeline monitoring and metrics.

- Author: Matt Langsenkamp
- Repository: MattLangsenkamp/zio-lucene-test
- Version: 20260119151140
- Stars: 0
- Forks: 0
- Last Updated: 2026-02-06
- Source: https://github.com/MattLangsenkamp/zio-lucene-test
- Web: https://mule.run/skillshub/@@MattLangsenkamp/zio-lucene-test~data-pipeline:20260119151140

---

---
name: data-pipeline
description: Data pipeline development with Kafka, stream processing, SSE integration, and Wikipedia EventStreams. Use when working on: (1) Kafka consumer and producer implementation, (2) Stream processing with ZIO-streams, (3) Server-Sent Events (SSE) integration, (4) Wikipedia EventStreams API consumption, (5) Data transformation and enrichment, (6) Backpressure and flow control, (7) Stream error handling and recovery, (8) Message serialization and deserialization, or (9) Pipeline monitoring and metrics.
---

# Data Pipeline Agent

This skill is under development. Content will be added in future iterations.