Apache Kafka agent skills, page 2

Create reproducible, cross-platform (macOS/Linux) development environments with Flox, a declarative Nix-based environment manager.

affaan-m/ECC

World-class data engineering skill for building scalable data pipelines, ETL/ELT systems, and data infrastructure.

davila7/claude-code-templates

File an interview question and answer into doc/faq/ in the shape the other 49 FAQs use — the sheet its Scope line owns, the numbered section it belongs under, tagged code fences — and write the…

yennanliu/CS_basics

ELK Stack deployment, Logstash pipeline building, Filebeat configuration, and Kibana dashboard setup.

aspectrr/deer

解答与开源产品有关的深度技术问题，输出图文并茂的 Markdown 技术文章。触发条件：用户提出与开源项目（如 PostgreSQL、Redis、Kafka、Kubernetes、ClickHouse、Flink 等）相关的技术问题，并提供源码目录或 URL、deepwiki repo 名称。即使用户只说"帮我解答这个开源问题"或"分析一下这个项目的某个机制"，也应使用本…

digoal/blog

A skill your agent uses when deploying, operating, integrating, or customizing the VSS RT-Embed Video Embedding microservice.

NVIDIA-AI-Blueprints/video-search-and-summarization

Async communication patterns using message brokers and task queues.

ancoleman/ai-design-components

Deep dive into flowfileframe — the Polars-LazyFrame-shaped Python API that builds an in-process flowfilecore FlowGraph as a side effect of every method call — covering the FlowFrame/Expr internals…

Edwardvaneechoud/Flowfile

Configures Spring Boot's Kafka starter through application.properties / application.yml.

Amplicode/spring-skills

Build event streaming and real-time data pipelines with Kafka, Pulsar, Redpanda, Flink, and Spark.

ancoleman/ai-design-components

A skill your agent uses when implementing Kafka, RabbitMQ, Pulsar, or JMS producers and consumers in Spring Boot 3.

rrezartprebreza/spring-boot-skills

A skill your agent uses when implementing Kafka, RabbitMQ, Pulsar, or JMS producers and consumers in Spring Boot 4.

rrezartprebreza/spring-boot-skills

Data engineering knowledge reference covering Airflow, Dagster, Kafka Streams, Flink, dbt, and data quality patterns.

telagod/code-abyss

Configure and operate the Neo4j Connector for Kafka (sink + source) and the native Neo4j CDC API.

neo4j-contrib/neo4j-skills

A skill your agent uses when you need to select, review, or implement Java design and integration patterns — including classic Java design patterns, REST API patterns, Kafka and event-driven…

jabrena/plinth

A skill your agent uses when you need to implement acceptance tests from maintainer-sanitized Gherkin scenario facts for framework-agnostic Java (no Spring Boot, Quarkus, Micronaut) — confirming…

jabrena/plinth

A skill your agent uses when you need to design or implement Kafka messaging in Spring Boot — including topic design, producer/consumer implementation, JSON serialization with Boot factory…

jabrena/plinth

A skill your agent uses when you need to implement acceptance tests from maintainer-authored or maintainer-sanitized Gherkin scenario facts for Spring Boot applications — including selecting…

jabrena/plinth

A skill your agent uses when you need Kafka messaging in Quarkus with SmallRye Reactive Messaging — including channel/topic design, build-time Jackson serialization, typed @Channel/@Incoming…

jabrena/plinth

A skill your agent uses when you need Kafka messaging in Micronaut — including @KafkaClient and @KafkaListener design, @Serdeable serialization, topic/partition strategy, TestPropertyProvider…

jabrena/plinth

Data engineering for batch and streaming pipelines with Airflow, dbt, Spark, and Kafka.

borghei/Claude-Skills

A Lead Data Engineer interviewer evaluating asynchronous messaging.

PrepLabsAI/InterviewMentor

Define event-driven APIs over Kafka with Mendix business event services — publish and subscribe contracts, CREATE/DROP/DESCRIBE.

mendixlabs/mxcli

Deploy and operate apps on Sealos Cloud: sign in to a Sealos account, deploy any project or self-hosted app (from the template store, an official Docker image, or project source code), provision…

hashgraph-online/awesome-codex-plugins

Enable Data Streams Monitoring (DSM) on services already instrumented with APM, for end-to-end latency, throughput, and consumer lag across Kafka, RabbitMQ, SQS, SNS, Kinesis, Pub/Sub, IBM MQ, Azure…

datadog-labs/agent-skills

Provides Event-Driven Architecture (EDA) patterns for Spring Boot — creates domain events, configures ApplicationEvent and @TransactionalEventListener, sets up Kafka producers and consumers, and…

giuseppe-trisciuoglio/developer-kit

Provides distributed transaction patterns using the Saga Pattern for Spring Boot microservices.

giuseppe-trisciuoglio/developer-kit

Data pipeline contract enforcer. An agent skill from LeoYeAI/openclaw-master-skills.

LeoYeAI/openclaw-master-skills

标准 SOP：OceanBase 社区版经 OMS 同步至 Kafka 的延迟、吞吐与调优。涵盖全量/增量并发与限速、KafkaSink、OMS 平台 limitator 与 JVM、源端 OB 与表结构策略；与 observer 日志、OBProxy、单条 SQL 深查 skill 分工明确。

oceanbase/obdiag

Expert data engineer for ETL/ELT pipelines, streaming, data warehousing.

curiositech/some_claude_skills

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…

Kilo-Org/kilo-marketplace

Architect, build, and debug Kafka Streams apps (JVM-embedded stream processing).

Kilo-Org/kilo-marketplace

Kafka 消息队列学习与选型指南。面向需要了解 Kafka 的开发者，提供核心概念、安装部署、生产者/消费者模型、消息可靠性、与业务场景匹配推荐、设计规则等（不含具体框架集成，Spring Boot 集成请用 springboot-kafka-module-skill，Python 集成请用 python-kafka-module-skill）。触发词："Kafka 学习"、"Kafka…

jiushiwon/wg-skills

Configures Dapr pub/sub components for event-driven microservices with Kafka or Redis.

aiskillstore/marketplace

Deploys Apache Kafka on Kubernetes using the Strimzi operator with KRaft mode.

aiskillstore/marketplace

AsyncAPI specification handling for event-driven API documentation.

majiayu000/claude-skill-registry

A skill your agent uses when designing or debugging an event-driven system — choosing Kafka partitioning strategies, implementing the outbox pattern, handling dead-letter queues, ensuring idempotent…

kid-sid/claude-spellbook

Guides development and usage of I/O connectors in Apache Beam.

Kilo-Org/kilo-marketplace

Query Prometheus monitoring metrics and alert rules. An agent skill from Kilo-Org/kilo-marketplace.

Kilo-Org/kilo-marketplace

Best practices for Apache Kafka event streaming and distributed messaging.

Mindrally/skills

Full pipeline for building web scraping systems with agent team collaboration.

revfactory/harness-100

Elite Data Engineer skill with expertise in building scalable data pipelines, ETL/ELT processes, data warehousing (Snowflake, BigQuery, Redshift), streaming (Kafka, Spark Streaming), and data lake…

theneoai/awesome-skills

Apache Kafka expert: topic design, partitioning, consumer groups, Kafka Streams, Kafka Connect, schema registry, and production operations.

theneoai/awesome-skills

Python Kafka 模块快速集成技能。面向已拥有 FastAPI 项目骨架的开发者，提供 Kafka 生产者、消费者、消息订阅、事件驱动等能力的快速集成。触发词："Python Kafka"、"FastAPI Kafka"、"Kafka 集成"、"kafka producer"、"kafka consumer"、"kafka 消息"、"kafka 事件"、"kafka 队列"。

jiushiwon/wg-skills

Spring Kafka 模块快速集成技能。面向已拥有 Spring Boot 项目骨架的开发者，提供 Kafka 生产者、消费者、消息订阅、事件驱动等能力的快速集成。触发词："Spring Kafka"、"Spring Boot Kafka"、"Kafka 集成"、"kafka producer"、"kafka consumer"、"kafka 消息"、"kafka 事件"、"kafka…

jiushiwon/wg-skills

Message queue patterns with BullMQ, Kafka, RabbitMQ - saga, outbox, dead letter queue, exactly-once semantics.

vibeeval/vibecosystem

Topic design, partition strategies, consumer group patterns, exactly-once processing, and dead letter queue handling.

vibeeval/vibecosystem

Event-driven architecture expertise covering event sourcing, CQRS, message brokers (Kafka, RabbitMQ), saga patterns, eventual consistency, idempotency, event schema design, dead letter queues, and…

FerroxLabs/wayland