Plugin streaming-skills-plugin per Claude

Configura pipeline end-to-end di Change Data Capture (CDC) su Confluent Cloud usando connettori sorgente Debezium, Flink per la trasformazione e Tableflow per l'integrazione con il data lake. Supporta i formati JSON_SR, Avro e Protobuf…

Scrivi e correggi SQL Flink che gira su Confluent Cloud, rispettando il confine tra dialetto CC e Apache Flink (OSS). Usalo quando la directory di lavoro è uno spazio di lavoro Flink di Confluent Cloud, o quando un'istruzione SQL Flink deve essere cambiata…

Crea skill specifiche di Confluent per utenti esterni. Usa questa skill quando gli utenti vogliono creare, costruire o scrivere una nuova skill legata a Confluent Cloud, Confluent Platform, Apache Kafka, WarpStream, Flink, connettori…

Rivedi una skill agente Confluent in questo repo rispetto alla specifica Agent Skills (agentskills.io), alle convenzioni Confluent in CLAUDE.md, ai controlli del template PR e alla regola evals-as-contract. Usa questa skill ogni volta che l'utente…

Ottimizzazione Kafka solo consultiva per Confluent Cloud o Confluent Platform, in base alla priorità: latenza, throughput, disponibilità o durabilità. Usalo quando si chiede di dimensionare un topic pianificato o ottimizzare un cluster, topic, producer…

Usalo quando l'utente vuole integrare un client Kafka in un'applicazione esistente o creare lo scaffold di un progetto client Kafka Java (basato su Maven o Gradle) per Confluent Cloud, Docker locale o WarpStream. Copre il client Apache Kafka…

Usalo quando l'utente vuole costruire un producer o consumer Kafka in Python, aggiungere Schema Registry a codice Python esistente, migrare da JSON grezzo a serializzazione basata su schema, o creare lo scaffold di un progetto confluent-kafka-python per…

Costruisci e distribuisci user-defined function (UDF) Apache Flink in Java per l'elaborazione di stream su Kafka. Usa questa skill quando gli utenti vogliono creare UDF scalari, funzioni di tabella definite dall'utente (UDTF) o funzioni di tabella di processo…

Genera uno script di creazione di topic Confluent Cloud con controlli di idempotenza. Usalo quando l'utente chiede di creare un topic, predisporre topic o scrivere un `create-topics.sh` per Confluent Cloud. NON attivare per Kafka self-managed…

Genera una dashboard del lag dei consumer group Kafka. Usalo quando l'utente chiede di monitorare il lag, costruire una dashboard per il lag dei consumer o collegare exporter Prometheus per Kafka. NON attivare per metriche dei producer, JMX dei broker o…

Analizza un progetto per identificare applicazioni Kafka, estrarre schemi dai modelli di dati, etichettare i campi PII, generare Terraform per la registrazione in Confluent Schema Registry e produrre un report di migrazione con ordine di rilascio. Usalo…

Progetta, costruisci e fai il debug di app Kafka Streams (elaborazione di stream incorporata nella JVM). Usalo quando l'utente menziona KStream, KTable, topologia, TopologyTestDriver, StreamsBuilder, query interattive, GlobalKTable, join, finestre e a…

Arricchisci uno stream di ordini cliente con il livello fedeltà usando Flink SQL su Confluent Cloud. Usalo quando l'utente vuole unire un topic di ordini con una tabella clienti ed emettere un topic arricchito. NON attivare per self-managed…

Usa questa skill per valutare e pianificare una migrazione da AWS MSK (Managed Streaming for Apache Kafka) a Confluent Cloud. Si attiva su intenti dell'utente come «migra MSK su Confluent Cloud», «esci da MSK», «cutover da MSK a CC», «…

Genera un report di compatibilità dello Schema Registry per gli schemi Avro di un progetto. Usalo quando l'utente chiede di verificare la compatibilità Avro, validare l'evoluzione degli schemi o segnalare modifiche incompatibili. NON attivare per Protobuf, JS…

Costruisci uno script di provisioning dei topic Confluent Cloud con retention e compattazione. Usalo quando l'utente chiede di creare un topic, scrivere un `create-topics.sh`, impostare la retention o la politica di compattazione, predisporre topic per Conflue…