confluentinc

Create Confluent-specific skills for external users. Use this skill when users want to create, build, or author a new skill related to Confluent Cloud, Confluent Platform, Apache Kafka, WarpStream, Flink, Connectors, Schema Registry, Tableflow, CDC pipelines,…

Use 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 Cloud, local Docker, or WarpStream. Covers the Apache Kafka Java clients…

Use this skill to assess and plan a migration from AWS MSK (Managed Streaming for Apache Kafka) to Confluent Cloud. Triggers on user intent like "migrate MSK to Confluent Cloud", "move off MSK", "MSK to CC cutover", "Zero-Cut migration from MSK", "kcp scan my…

Enrich a customer-orders stream with loyalty tier using Flink SQL on Confluent Cloud. Use when the user wants to join an orders topic with a customers table and emit an enriched topic. Do NOT trigger for self-managed Kafka, connector setup, or Schema Registry…

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. Use this skill whenever the user asks to review, audit, validate, or lint a…

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. Supports JSON_SR, Avro, and Protobuf formats. Handles schemaless topics (plain JSON…

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, or…

Build and deploy Apache Flink user-defined functions (UDFs) in Java for stream processing over Kafka. Use this skill when users want to create scalar UDFs, user-defined table functions (UDTFs), or process table functions (PTFs) in Java, deploy them to…

Use when the user asks about Mocha test runner APIs and patterns for unit tests. Triggers on questions like "Mocha hooks", "before/after setup", "describe/it structure", "async tests in Mocha", "test timeouts", ".only/.skip", "how to run a specific test", or…

Use when the user asks about Playwright APIs, selectors, assertions, or patterns for E2E or functional tests. Triggers on questions like "how to click a button in Playwright", "Playwright locator", "page.waitFor", "expect toBeVisible", "Playwright test…

Use when E2E Playwright tests fail, CI reports test failures, the user mentions "triage", "test failed", "flaky test", or wants to debug Electron/Playwright test results. Also use when investigating trace.zip files, test screenshots, or Playwright HTML report…

Reviews pull requests for this VS Code extension. Use when reviewing PRs, doing self-review before sharing with the team, or when user mentions "review PR", "review changes", "self-review", or "check my PR". Focuses on project-specific patterns and critical…

Use when the user asks about Sinon stubbing, spying, mocking, or test double APIs for unit tests. Triggers on questions like "how do I stub this", "Sinon fake timers", "spy vs stub", "sandbox usage", "assert.calledWith", "stub.resolves", "sinon.match", or…

Use when the user asks about VS Code API definitions, methods, interfaces, events, types, or wants to understand what VS Code APIs are available. Triggers on questions like "what does vscode.X do", "how to use VS Code API", "VS Code type definition", or…

Command reference for the F1 Pit Wall workshop — create/teardown a workshop, workshop subcommands, credential cards, race control (start/stop/reset), standalone deploy, self-service, f1-pitwall, f1-social-feed, setup-mcp, tests and lint. Load this when…

The three Terraform tiers in this repo and how they relate — aws-shared (applied once) vs aws (per attendee) vs self-service (Confluent-only), the shared llm module, per-attendee resource naming and CDC slot isolation, the max_replication_slots=105 sizing…

How attendee logins, passwords, deployment prefixes, and credential cards actually resolve in this repo — the three moving parts of Confluent Cloud Console access (invited users, 1Password passwords, grant_console_access RBAC), the derived per-track…

How this repo drives the wsa CLI (workshop-setup-accelerator) for organizer provisioning — binary discovery, the wsa-spec-aws.yaml contract, account_count vs --attendees, Terraform path contract, secrets, the dispenser upload, and the clean/teardown gotchas…

Reviews pull requests for the Confluent MCP server. Use when reviewing PRs, doing self-review before sharing with the team, or when the user mentions "review PR", "help with PR", "review changes", "self-review", "review local changes", or "check my PR".…

Use when the user asks about Model Context Protocol details (protocol spec, transports, authorization, tools/resources/prompts, sampling/elicitation/roots, server/client concepts, extensions, or SDK usage). Triggers on phrases like "MCP spec", "MCP…

Use when the user asks about Vitest mocking, spies, stubs, fake timers, config, or test runner behavior. Triggers on questions like "vi.fn", "vi.spyOn", "vi.mocked", "Mocked<T>", "mockResolvedValue", "restoreMocks", "vitest mock", "createMockInstance",…

Reviews pull requests for the Confluent CLI. Use when reviewing PRs, doing self-review before sharing with the team, or when the user mentions "review PR", "help with PR", "review changes", "self-review", "review local changes", or "check my PR". Focuses on…

Validates confluentinc/cli's in-code documentation (Short/Long/Example text on Cobra commands, plus root markdown like README.md/CONTRIBUTING.md) against the live command tree to catch stale references to deprecated or hidden commands/flags,…

Finds and resolves duplicate GitHub issues in confluentinc/cli, with a lightweight check for related issues in the sibling confluentinc/terraform-provider-confluent repo. Scans open issues, clusters likely duplicates with a suggested canonical issue, and —…

Reviews pull requests for the Confluent Terraform provider. Use when reviewing PRs, doing self-review before sharing with the team, or when the user mentions "review PR", "help with PR", "review changes", "self-review", "review local changes", or "check my…

Validates confluentinc/terraform-provider-confluent's docs/ (resources, data-sources, guides) and examples against the actual Go schema definitions to catch stale references to deprecated or renamed resources/attributes, wrong/missing/extra attributes vs.…

Finds and resolves duplicate GitHub issues in confluentinc/terraform-provider-confluent, with a lightweight check for related issues in the sibling confluentinc/cli repo. Scans open issues, clusters likely duplicates with a suggested canonical issue, and —…

IntelliJ Platform SDK lookup for plugin development. Use when the user asks about IntelliJ Platform APIs, extension points, threading rules, PSI, VFS, services, UI components, or how to implement plugin features. Triggers on questions like "how do I create a…

Guide writing unit tests for the Kafka IntelliJ plugin. Use when the user asks to "write tests", "add unit tests", "test this component", or needs help testing services, actions, UI panels, or data models in isolation. Also triggers on "how do I test", "mock…

Review pull requests for the Kafka IntelliJ plugin. Checks for IntelliJ Platform best practices, threading safety, proper service usage, localization, and project-specific patterns. Use when reviewing PRs, doing self-review before sharing with the team, or…

Use when the user asks about GraalVM native image compilation, reflection registration, native build failures, or native executable testing. Triggers on questions like "@RegisterForReflection", "native image build error", "reflection-config.json", "native…

Reviews pull requests for the ide-sidecar project. Use when reviewing PRs, doing self-review before sharing with the team, or when user mentions "review PR", "help with PR", "review changes", "self-review", "review local changes", or "check my PR". Provides…

Use when the user asks about Quarkus framework APIs, CDI dependency injection, SmallRye Mutiny reactive programming, JAX-RS REST endpoints, Quarkus testing, or application configuration. Triggers on questions like "how does @Inject work", "Uni vs Multi",…