confluentinc/agent-skills
15 skills · 356 total installs
$npx skills add confluentinc/agent-skillsSkillInstalls
kafka-schema-registryScan a project to identify Kafka applications, extract schemas from data models, tag PII fields, generate Terraform for Confluent Schema Registry registration,…developing-kafka-python-clientUse 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…kafka-streams-programmingArchitect, build, and debug Kafka Streams apps (JVM-embedded stream processing).confluent-cloud-cdc-tableflowSet up end-to-end Change Data Capture (CDC) pipelines on Confluent Cloud using Debezium source connectors, Flink for transformation, and Tableflow for data…confluent-skill-reviewerReview 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…confluent-skill-creatorCreate Confluent-specific skills for external users. Use this skill when users want to create, build, or author a new skill related to Confluent Cloud,…flink-udfBuild and deploy Apache Flink user-defined functions (UDFs) in Java for stream processing over Kafka.msk-migrationUse this skill to assess and plan a migration from AWS MSK (Managed Streaming for Apache Kafka) to Confluent Cloud.developing-kafka-java-clientUse when the user wants to integrate a Kafka client into an existing application or scaffold a Java Kafka client project (Maven or Gradle based) for Confluent…bad-frontmattergood-skillGenerate a Confluent Cloud topic creation script with idempotency checks.inlined-refsGenerate a Kafka consumer group lag dashboard. Use when the user asks to monitor lag, build a dashboard for consumer lag, or wire up Prometheus exporters for…leaky-dataEnrich a customer-orders stream with loyalty tier using Flink SQL on Confluent Cloud.stale-expectationsGenerate a Schema Registry compatibility report for Avro schemas in a project.trigger-overlapBuild a Confluent Cloud topic provisioning script with retention and compaction.