KafkaJS consumer 그룹을 사용하여 실시간 이벤트 스트림을 처리하고, 구성 가능한 스키마로 메시지를 변환합니다. 파티션 리밸런싱, 오프셋 커밋 및 실패한 변환에 대한 데드 레터 큐 라우팅을 처리합니다.
Apache Kafka 스트림 변환기는 실시간 이벤트 스트림 처리를 위한 AI 에이전트 스킬로, KafkaJS consumer 그룹을 활용하여 메시지를 수신하고, 사용자가 정의한 스키마에 따라 변환한 후 결과를 다시 Kafka 토픽에 전송합니다. 이 스킬은 파티션 리밸런싱, 오프셋 커밋과 같은 Kafka의 고급 기능을 자동으로 처리하며, 변환에 실패한 메시지를 데드 레터 큐(DLQ)로 라우팅하여 데이터 손실을 방지합니다. 주로 Apache Kafka 생태계에서 동작하며, Docker를 통해 Kafka 브로커를 실행하거나 기존 클러스터에 연결하여 사용할 수 있습니다. 개발자는 JAR 빌드, Gradle 기반의 통합 테스트 실행 등의 표준 Kafka 개발 워크플로우를 지원받을 수 있으며, 관련 문서와 공식 저장소에 대한 링크를 참고할 수 있습니다.
npx skills add https://github.com/agentskillexchange/skills/tree/main/skills/apache-kafka-stream-transformer-2실시간 이벤트 스트림을 KafkaJS consumer 그룹을 사용하여 처리하고, 구성 가능한 스키마로 메시지를 변환합니다. 파티션 리밸런싱, 오프셋 커밋 및 실패한 변환에 대한 데드 레터 큐 라우팅을 처리합니다.
환경에 맞는 업스트림 설치 또는 설정 경로를 사용하세요:
업스트림 요구 사항 및 주의사항:
기본 사용법 및 시작 참고 사항:
./gradlew test -Pkafka.test.run.flaky=true # flaky로 표시된 테스트 실행
업스트림 문서에서 추출: https://raw.githubusercontent.com/apache/kafka/HEAD/README.md
This repo contains 20 individual skills — each has its own dedicated page.
Builds citation networks from Semantic Scholar API and CrossRef DOI metadata. Visualizes paper influence graphs using NetworkX, identifies seminal works, and tracks research lineage across fields.
Exposes Advanced Custom Fields data through the WordPress REST API using register_rest_field and acf_format_value. Handles repeater fields, flexible content layouts, and gallery fields with proper serialization.
An ASE skill built around ACF Extended, the WordPress enhancement suite for Advanced Custom Fields that adds field types, admin improvements, front-end forms, options pages, and developer tooling. It is a practical fit for agents working inside complex WordPress content models and custom field workflows.
Converts Advanced Custom Fields field groups into native Gutenberg blocks using the ACF Block API v2 and @wordpress/scripts build pipeline. Maps ACF repeaters, groups, and flexible content to InnerBlocks and block attributes with server-side rendering via acf_register_block_type().
Activepieces is an open-source, self-hostable workflow automation platform with 200+ integrations. It provides a visual builder for creating automated workflows and exposes all its connectors as MCP servers for AI agent use.
ActivityWatch is a privacy-first, open-source automated time tracker that records application usage, browser activity, and AFK status across Windows, macOS, and Linux. With 16k+ GitHub stars, it provides detailed productivity analytics without sending data to external servers.
act is an open-source CLI tool that runs GitHub Actions workflows locally using Docker, enabling fast feedback on workflow changes without pushing to GitHub. It is a standard tool for local Actions development and testing.
Use AgentClick when an agent should pause before risky commands, plans, drafts, or code changes so a human can inspect, edit, approve, or reject them in a purpose-built browser UI.
Use UX/UI Agent Skills when Claude should generate tokens, component specs, accessibility audits, and framework-specific UI code from a repeatable design workflow.
Use Bats-core when an agent needs to turn fragile shell scripts or command-line workflows into something it can verify repeatedly after edits. The agent writes focused Bash tests for success paths, failure paths, and output contracts, then runs them locally or in CI before a refactor, release, or incident fix goes out.
Use Cognee to ingest project knowledge into graph and vector memory so agents can retrieve durable context across sessions and workflows.
Give a coding agent symbol-aware lookup, cross-file rename, and structural edit tools before it starts making brittle text-only changes.
Give LangGraph agents memory management and search tools so they can store, retrieve, and update durable facts across sessions.
Use SimpleMem to store, compress, index, and retrieve text or multimodal memories for agents through MCP or Python integrations.
Keep Claude Code sessions grounded in prior decisions, project context, and daily handoff notes instead of starting from zero every time.
Store embeddings beside application data in Postgres, create vector indexes, and query nearest neighbors for semantic search, RAG, recommendations, or agent memory retrieval.
Find the open PR for the current branch, gather unresolved review comments, and drive a focused comment-resolution workflow with gh-authenticated context.
Use VoltAgent to intercept, validate, and enforce input/output policies in TypeScript agent workflows.
Use Zep as an external context layer for agents that need to store events, assemble temporal graph context, and retrieve relevant memory before model calls.
Calls Adobe Firefly
Extract frames or short clips from videos using ffmpeg.
Summarize or transcribe URLs, YouTube/videos, podcasts, articles, transcripts, PDFs, and local files.
Use when testing, fixing, or extending the OpenClaw Control UI GUI with Vitest + Playwright end-to-end checks, mocked Gateway WebSocket flows, mocked dashboard runs, screenshots/videos, or agent-verifiable browser proof.
Obra superpowers agent skills.
See, Understand, Act on video and audio. See- ingest from local files, URLs, RTSP/live feeds, or live record desktop; return realtime context and playable stream links. Understand- extract frames, build visual/semantic/temporal indexes, and search moments with timestamps and auto-clips. Act- transcode and normalize (codec, fps, resolution, aspect ratio), perform timeline edits (subtitles, text/image overlays, branding, audio overlays, dubbing, translation), generate media assets (image, audio...
End-to-end marketing campaign planning and execution. Covers audience research, positioning, campaign angle definition, landing page copy, email sequences, social posts, ad copy, short-form video scripts, and content calendars. Use as the orchestration layer for multi-channel product launches. Use when planning or executing a multi-channel product launch, or producing landing page, email, social, or ad copy.