Standardize Kafka event production and consumption with schema registry integration.
npx skills add https://github.com/pessinamistic/pitwall --skill kafka-pessinamistic
Please help me install this Agent Skill. Skill: kafka Source: https://github.com/pessinamistic/pitwall/tree/main/.claude/skills/kafka Command: npx skills add https://github.com/pessinamistic/pitwall --skill kafka-pessinamistic
This skill addresses the complexity of maintaining reliable, idempotent, and scalable event-driven architectures by providing standardized patterns for Kafka producers and consumers.
Use the kafka skill to validate your consumer implementation against the project's idempotency and retry requirements.
High-intent search queries and answers about installing and using this skill.
Implementing an idempotent Kafka consumer requires standardized processing logic to track consumed events, preventing data duplication and ensuring reliable event-driven microservices execution. This approach maintains strict ordering and high availability.
Handling Kafka consumer retries without blocking partitions is achieved using non-blocking retry topics. This operational best practice prevents partition stalls and data loss during transient processing failures in event-driven architectures.
Schema registry integration with Avro serialization enforces compatibility checks to ensure seamless service evolution. It governs schema changes, preventing breaking changes during the production and consumption of Kafka events.
You need the atomic outbox pattern for Kafka event streaming when ensuring reliable, scalable event-driven architectures. It guarantees database state changes and event publications occur together, preventing data inconsistency.
Yes, applying Spring Kafka best practices defines clear conventions for topic naming, partition key selection, and consumer group management. This standardization prevents common production incidents in high availability environments.
AbdullahMalik17Deploy Kafka clusters on Kubernetes using the Strimzi operator in KRaft mode.
ririntoBuild Spring Kafka producers and consumers with retry, DLT, and embedded Kafka tests.
saddam-eng-techScaffold the transactional outbox pattern for Go microservices with Kafka publishing.
manutejImplement Apache Kafka producers, consumers, streams, and connectors for real-time data processing.
