Skip to content

fix: resolve Kafka deserialization issues and enable Kafka UI connect…#3

Merged
kivo2 merged 1 commit into
mainfrom
phase3a_demo
Apr 3, 2026
Merged

fix: resolve Kafka deserialization issues and enable Kafka UI connect…#3
kivo2 merged 1 commit into
mainfrom
phase3a_demo

Conversation

@kivo2

@kivo2 kivo2 commented Apr 3, 2026

Copy link
Copy Markdown
Owner

…ivity

Phase 3a was blocked by two critical issues:

  1. Workers/orchestrator couldn't deserialize Kafka messages
  2. Kafka UI couldn't connect to broker

Fixes:

  • Add VALUE_DEFAULT_TYPE config to worker Kafka consumers
  • Switch orchestrator to StringJsonMessageConverter with JavaTimeModule
  • Configure Kafka with dual listeners (INTERNAL/EXTERNAL) for Docker networking
  • Disable type headers in JSON serialization across all services

Result: End-to-end async saga orchestration now working ✓

Resolves: Saga stuck at RESERVE_INVENTORY
Resolves: Kafka UI showing offline status

…ivity

  Phase 3a was blocked by two critical issues:
  1. Workers/orchestrator couldn't deserialize Kafka messages
  2. Kafka UI couldn't connect to broker

  Fixes:
  - Add VALUE_DEFAULT_TYPE config to worker Kafka consumers
  - Switch orchestrator to StringJsonMessageConverter with JavaTimeModule
  - Configure Kafka with dual listeners (INTERNAL/EXTERNAL) for Docker networking
  - Disable type headers in JSON serialization across all services

  Result: End-to-end async saga orchestration now working ✓

  Resolves: Saga stuck at RESERVE_INVENTORY
  Resolves: Kafka UI showing offline status
@kivo2 kivo2 merged commit c696568 into main Apr 3, 2026
1 check failed
@kivo2 kivo2 deleted the phase3a_demo branch April 3, 2026 19:36
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