Apache Kafka and data-streaming skills from Confluent.
Official Confluent skills for streaming applications, governance, CDC, and skill authoring/review.
Arranged in the author's recommended order. Walk through them in sequence, or open any one on its own.
Build and deploy Apache Flink user-defined functions (UDFs) in Java for stream processing over Kafka.
Scan a project to identify Kafka applications, extract schemas from data models, tag PII fields, generate Terraform for Confluent Schema Registry registration, and produce a migration report with rollout ordering.
Architect, build, and debug Kafka Streams apps (JVM-embedded stream processing).
Use when the user wants to build a Python Kafka producer or consumer, add Schema Registry to existing Python code, migrate from raw JSON to schema-backed serialization, or scaffold a confluent-kafka-python project for Confluent Cloud, local Docker.
Set up end-to-end Change Data Capture (CDC) pipelines on Confluent Cloud using Debezium source connectors, Flink for transformation, and Tableflow for data lake integration.
Review a Confluent agent skill in this repo against the Agent Skills spec (agentskills.io), Confluent conventions in CLAUDE.md, the PR template gates, and the evals-as-contract rule.
Create Confluent-specific skills for external users.