Apache Kafka

Guide for using the Grafana MCP to monitor and diagnose the capture service (rust/capture) in production.

PostHog/posthog

Scaffold a standalone RTVI CV microservice that plugs into VSS Search and Alerts profiles via Kafka mdx-raw.

NVIDIA/skills

Guide for using the Grafana MCP to monitor and diagnose the Node.js ingestion pipeline workers in production.

PostHog/posthog

Helps migrate self-managed Apache Kafka workloads to Amazon MSK Express.

aws/agent-toolkit-for-aws

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

ancoleman/ai-design-components

Operates Amazon MSK Provisioned clusters (Standard and Express brokers).

aws/agent-toolkit-for-aws

Train ML models on Databricks. An agent skill from databricks/databricks-agent-skills.

databricks/databricks-agent-skills

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

telagod/code-abyss

NVIDIA DeepStream SDK development with Python pyservicemaker API.

NVIDIA/skills

Run and operate the DeepStream Multi-View 3D Tracking reference app, also known as MV3DT.

NVIDIA/skills

A skill your agent uses when building, deploying, evaluating, debugging, or measuring latency for the DeepStream SOP Inference Microservice — a GPU-accelerated FastAPI service that detects whether…

NVIDIA/skills

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

NVIDIA/skills

A skill your agent uses to deploy the vss-video-analytics-api REST service standalone (config-source, data-log bind, Elasticsearch, optional Kafka).

NVIDIA/skills

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

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

Amazon MSK Provisioned operations, troubleshooting, and health assessment for Standard and Express brokers.

aws/tools-for-devops-agent

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

Ingest data into ClickHouse from webhooks, Kafka, and streaming sources with batching, dedup, and exactly-once patterns.

jeremylongshore/tons-of-skills-marketplace

Consume Guidewire App Events into downstream systems (SQS/SNS, Kafka, webhooks) and survive the event-side failures — events not firing because Gosu registration was missed, duplicates from queue…

jeremylongshore/tons-of-skills-marketplace

Dispatch LangChain 1.0 chain/agent events to external systems — webhooks, Kafka, Redis Streams, SNS — via async fire-and-forget callbacks, subgraph-aware wiring, and HMAC-signed delivery with…

jeremylongshore/tons-of-skills-marketplace

Configure Sentry error tracking and performance monitoring for different application architectures.

jeremylongshore/tons-of-skills-marketplace

Push records from apps, services, devices, or scripts directly into Unity Catalog Delta tables with Zerobus Ingest: SDKs (Python, TypeScript, Go, Java, Rust, C++, .NET), REST, OTLP, MQTT, Arrow…

databricks/databricks-agent-skills

Guides general use of AWS messaging and streaming services. An agent skill from aws/agent-toolkit-for-aws.

aws/agent-toolkit-for-aws

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

Manage kafka producer consumer operations. An agent skill from jeremylongshore/tons-of-skills-marketplace.

jeremylongshore/tons-of-skills-marketplace

Process kafka stream processor operations. An agent skill from jeremylongshore/tons-of-skills-marketplace.

jeremylongshore/tons-of-skills-marketplace

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

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

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

Selects, investigates, and compares AWS object, file, and block storage services, and answers cost, performance, configuration, security, and troubleshooting questions about storage services.

aws/agent-toolkit-for-aws

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

Expert knowledge for Azure Event Hubs development including troubleshooting, best practices, decision making, architecture & design patterns, limits & quotas, security, configuration, integrations &…

MicrosoftDocs/Agent-Skills