17 tagged flink, measured the same way as everything else here.
Browse within: cdc 16confluent 16kafka 16
Skill Claude CodeCodex
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 JSONSR, Avro, and Protobuf formats. Handles schemaless topics (plain JSON without SR) and multi-event topics. This skill handles the…
Skill Claude CodeCodex
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 (KafkaProducer/KafkaConsumer/KafkaShareConsumer) with Avro, JSON Schema, or Protobuf…
Skill Claude CodeCodex
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 WarpStream. Also use when user wants to optimize Python Kafka…
Skill Claude CodeCodex
Create, generate, verify, or deploy Apache Flink streaming SQL jobs from a natural-language description — windowed aggregations (tumbling/hopping/session), running totals, top-N, deduplication, filters, and interval/temporal joins, plus Kafka topic->topic pipelines. Use whenever the user wants a Flink/streaming job…