skills.rest
Hamza123545
Hamza123545COMMUNITY
Explore all skills by this author →
GitHub

kafka-event-driven

Implement event-driven microservices with Apache Kafka via Dapr Pub/Sub.

1|Updated Dec 4, 2025
Search Tags:#event-driven#kafka#pub/sub#idempotency#dead-letter#dapr#producer-consumer
One-click install
npx skills add https://github.com/Hamza123545/Todo_giaic_five_phases --skill kafka-event-driven
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: kafka-event-driven
Source: https://github.com/Hamza123545/Todo_giaic_five_phases/tree/main/.claude/skills/kafka-event-driven
Command: npx skills add https://github.com/Hamza123545/Todo_giaic_five_phases --skill kafka-event-driven

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill enables building and operating event-driven microservices using Apache Kafka through Dapr Pub/Sub, simplifying decoupled communication and reliable messaging across services.

Core Features & Use Cases

  • Versioned Event Schemas: Supports evolving event structures with backward compatibility across services.
  • Producer/Consumer Patterns: Provides guidance and examples for publishing and consuming events via Dapr Pub/Sub.
  • Partitioning & Reliability: Implements user-id partitioning, retries, and dead-letter handling to improve fault tolerance.
  • Idempotency & Migration: Includes patterns to ensure idempotent processing and safe event schema evolution.

Quick Start

Run the examples in templates/event_publisher.py to publish events to Kafka via Dapr Pub/Sub. Ensure Dapr and Kafka are running locally, then observe the end-to-end event flow.

Frequently Asked Questions about kafka-event-driven

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
What is the best way to handle retries and dead-letter queues in Kafka pub/sub?▼

Versioned event schemas allow you to evolve event structures while maintaining backward compatibility across microservices. This ensures safe event schema migration without breaking existing consumers.

How do I ensure idempotent processing when consuming Kafka events via Dapr?▼

Yes, Dapr Pub/Sub supports user-id partitioning strategies for Kafka events. This partitions events to improve fault tolerance and ensure reliable message ordering across distributed services.

Why does my event schema migration break consumers in an event-driven architecture?▼

Yes, you need a running Dapr and Kafka environment to execute the Python-based publishers and consumers. This setup is required to observe the end-to-end event flow demonstrated in the templates.

How do I implement event-driven microservices with Kafka and Dapr?▼

Event schema migration breaks consumers when backward compatibility is not maintained. This Skill provides idempotency and migration patterns to ensure safe event schema evolution across services.

Related Skills

Explore More Software Engineering Skills→
Razaib-khanRazaib-khan

deploying-kafka-k8s

Deploy Apache Kafka on Kubernetes using the Strimzi operator.

Community
Advanced
aws-samplesaws-samples
12

messaging

Design AWS messaging patterns with SQS, SNS, and EventBridge.

Official
Advanced
ZaibunisZaibunis

async-dapr-client-service-coder

Generates Python code for Dapr integration with FastAPI endpoints and Pydantic models.

Community
Advanced
SyedaashnaghazanfarSyedaashnaghazanfar
2

kafka-event-driven

Configure Dapr Pub/Sub with Kafka for event-driven pipelines.

Community
Advanced