main
Use embedded Kafka for local Kafka integration test
refactor: decouple application from infrastructure
Add Kafka telemetry streaming pipeline