rwadurian/backend/services/referral-service/prisma
hailin 70d1a8bfb8 fix(referral): add idempotency check for Kafka event processing
- Add processed_events table to track handled events
- Check eventId before processing planting.created events
- Skip duplicate events and still send ACK to stop retries

This prevents data accumulation when Kafka events are redelivered
due to ACK failures or consumer timeouts.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2025-12-10 09:38:13 -08:00
..
migrations fix(referral): add idempotency check for Kafka event processing 2025-12-10 09:38:13 -08:00
schema.prisma fix(referral): add idempotency check for Kafka event processing 2025-12-10 09:38:13 -08:00