main
refactor: decouple application from infrastructure
Use embedded Kafka for local Kafka integration test