Skip to content

fix(consumer): harden job event listeners with idempotency, DLQ, and … - #31

Merged
hoangtuzami merged 1 commit into
mainfrom
test
May 16, 2026
Merged

fix(consumer): harden job event listeners with idempotency, DLQ, and …#31
hoangtuzami merged 1 commit into
mainfrom
test

Conversation

@hoangtuzami

Copy link
Copy Markdown
Member

…explicit Jackson mapping

  • Add idempotency check and MDC setup in handleJobCreated; route poison messages to job.created-dlq with reason codes (PARSE_FAILED / MISSING_REQUIRED_FIELDS).
  • Add 2-tier parsing fallback in parseJobCreatedEvent so cross-service Jackson version drift no longer drops events.
  • Add explicit @JsonProperty / @JsonIgnoreProperties / @JsonAutoDetect / @JsonCreator to JobCreatedEvent to stop silent null fields from polymorphic typing.
  • Localize default inspection note to Vietnamese.
  • Add KafkaConsumerConfig with DLT recoverer + producer factories.

…explicit Jackson mapping

- Add idempotency check and MDC setup in handleJobCreated; route poison messages to job.created-dlq with reason codes (PARSE_FAILED / MISSING_REQUIRED_FIELDS).
- Add 2-tier parsing fallback in parseJobCreatedEvent so cross-service Jackson version drift no longer drops events.
- Add explicit @JsonProperty / @JsonIgnoreProperties / @JsonAutoDetect / @JsonCreator to JobCreatedEvent to stop silent null fields from polymorphic typing.
- Localize default inspection note to Vietnamese.
- Add KafkaConsumerConfig with DLT recoverer + producer factories.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
@hoangtuzami
hoangtuzami merged commit a5ebd8e into main May 16, 2026
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant