Implementieren Sie typsichere Kafka-Konsumenten für den Ereigniskonsum mit msgspec-Deserialisierung. Wird beim Erstellen asynchroner Verbraucher verwendet, die Domänenereignisse (Bestellnachrichten, Transaktionen) verarbeiten. mit Offset-Management, Fehlerbehebung, ordnungsgemäßem Herunterfahren und verteilter Ablaufverfolgung. Verarbeitet Verbraucherkonfiguration, manuelle Commits und Rebalancing-Strategien.
Installieren Sie den KI-Skill kafka-consumer-implementation schnell in Ihrer Entwicklungsumgebung über die Kommandozeile
Quelle: dawiddutoit/custom-claude.
Implement production-grade Kafka consumers that reliably consume and process domain events with high performance, type safety, and comprehensive error recovery. Covers msgspec deserialization, confluent-kafka configuration, offset management, OpenTelemetry tracing, and anti-corruption layer patterns for translating message schemas to domain models.
Use when building event-driven systems that consume domain events from Kafka topics with "implement Kafka consumer", "consume events from Kafka", "process order messages", or "set up event consumer".
Do NOT use when mocking Kafka consumers in unit tests (use pytest-adapter-integration-testing), implementing producers (use kafka-producer-implementation), or testing with testcontainers (use kafka-integration-testing).
Implementieren Sie typsichere Kafka-Konsumenten für den Ereigniskonsum mit msgspec-Deserialisierung. Wird beim Erstellen asynchroner Verbraucher verwendet, die Domänenereignisse (Bestellnachrichten, Transaktionen) verarbeiten. mit Offset-Management, Fehlerbehebung, ordnungsgemäßem Herunterfahren und verteilter Ablaufverfolgung. Verarbeitet Verbraucherkonfiguration, manuelle Commits und Rebalancing-Strategien. Quelle: dawiddutoit/custom-claude.
Stabile Felder und Befehle für KI/Such-Zitate.
npx skills add https://github.com/dawiddutoit/custom-claude --skill kafka-consumer-implementationImplementieren Sie typsichere Kafka-Konsumenten für den Ereigniskonsum mit msgspec-Deserialisierung. Wird beim Erstellen asynchroner Verbraucher verwendet, die Domänenereignisse (Bestellnachrichten, Transaktionen) verarbeiten. mit Offset-Management, Fehlerbehebung, ordnungsgemäßem Herunterfahren und verteilter Ablaufverfolgung. Verarbeitet Verbraucherkonfiguration, manuelle Commits und Rebalancing-Strategien. Quelle: dawiddutoit/custom-claude.
Öffnen Sie Ihr Terminal oder Kommandozeilen-Tool (Terminal, iTerm, Windows Terminal, etc.) Kopieren Sie diesen Befehl und führen Sie ihn aus: npx skills add https://github.com/dawiddutoit/custom-claude --skill kafka-consumer-implementation Nach der Installation wird der Skill automatisch in Ihrer KI-Programmierumgebung konfiguriert und ist bereit zur Verwendung in Claude Code, Cursor oder OpenClaw
https://github.com/dawiddutoit/custom-claude