Backend & APIs · Apache Kafka

Checklist of every backend, frontend, CLI and capture change needed to add a new TriggerCrud-based trigger type, such as Azure, GCP or Kafka, to Windmill.

windmill-labs/windmill

A skill your agent uses when working with Foundatio infrastructure abstractions for .NET -- caching, queuing, messaging, file storage, distributed locking, or background jobs.

FoundatioFx/Foundatio

Helps DevOps engineers configure mirrord Operator's Kafka queue splitting feature end-to-end.

metalbear-co/mirrord

Add a new AWS event source attribute (e.g., Kinesis, Kafka, MQ) to the Lambda .NET Annotations framework, including the attribute class, source generator integration, CloudFormation writer, unit…

aws/aws-lambda-dotnet

Creates and debugs dubbo-go-pixiu HTTP-to-Dubbo route YAML. An agent skill from apache/dubbo-go-pixiu.

apache/dubbo-go-pixiu

A skill your agent uses when a user wants guidance on starting, contributing to, growing, governing, funding, securing, or sustaining an open source project, or asks about contributor onboarding…

calf-ai/calfkit-sdk

Creates and validates dubbo-go-pixiu LLM gateway conf.yaml. An agent skill from apache/dubbo-go-pixiu.

apache/dubbo-go-pixiu

Creates and validates dubbo-go-pixiu MCP gateway conf.yaml. An agent skill from apache/dubbo-go-pixiu.

apache/dubbo-go-pixiu

Guide for configuring, deploying, and operating the MonsterMQ broker.

vogler75/monster-mq

Create a new Whirl environment in the envs/ directory. An agent skill from godatadriven/whirl.

godatadriven/whirl

Create/modify/debug platform check. An agent skill from MaterializeInc/materialize.

MaterializeInc/materialize

Creates and debugs dubbo-go-pixiu HTTP/Network filters. An agent skill from apache/dubbo-go-pixiu.

apache/dubbo-go-pixiu

Implements backend modules from proto definitions for goddess, marksman, and rabbit apps.

aide-family/moon

Guide for configuring, managing, and mutating MonsterMQ settings, devices, flows, AI agents, users, loggers, archive groups, topic schemas, and publishing messages via the GraphQL API.

vogler75/monster-mq

Designs event stores for event-sourced systems: requirements, a comparison of EventStoreDB, PostgreSQL, Kafka, DynamoDB and Marten, and stream and versioning practices.

wshobson/agents

Comprehensive guide to Spark Structured Streaming for production workloads.

databricks/databricks-agent-skills

Migrate a Testcontainers guide from testcontainers.com into the Docker docs site (docs.docker.com).

docker/docs

A skill your agent uses when deploying or operating standalone RTVI-CV-3D / MV3DT multi-camera 3D tracking for calibrated MP4/file inputs and live RTSP streams: missing-calibration handoff to AMC…

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

Kafka topic management, consumer group monitoring, message production/consumption, and cluster health diagnostics.

aspectrr/deer

当需要为 funboost 任务选择消息中间件时使用。触发场景：对比 Redis/RabbitMQ/Kafka/本地队列、配置 broker 连接、设置 brokerexclusiveconfig。关键词：BrokerEnum, brokerkind, Redis, RabbitMQ, Kafka, MQTT, 中间件选型, 消息队列选择。

ydf0509/funboost

Step-by-step guide for adding a new queue transport to Agent Kernel's execution pipeline.

yaalalabs/agent-kernel

A skill your agent uses to deploy the vss-video-analytics-api REST service standalone with its Elasticsearch ingest-pipeline, selectable Kafka/Redis stream type, and Kafka-topic readiness gates when…

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

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

affaan-m/ECC

Manages MongoDB Atlas Stream Processing (ASP) workflows. An agent skill from mongodb/agent-skills.

mongodb/agent-skills

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

rrezartprebreza/spring-boot-skills

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

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

rrezartprebreza/spring-boot-skills

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

Debugs why session recordings aren't appearing in the local dev environment.

PostHog/posthog

A skill your agent uses when deploying standalone RT-VLM dense captioning or calling its REST API (uploads, captions, streams, chat-completions, Kafka).

NVIDIA/skills

Query tophog — the ingestion pipeline's heavy-hitter store in ClickHouse — to identify hot or expensive actors (teamid, distinctid, sessionid, partition) during incident triage.

PostHog/posthog

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

Amplicode/spring-skills

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

mendixlabs/mxcli

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

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

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