Consumer closes immediately when executed from spawned app within integration test

[lcmgh]

It is crazy. I start my StreamConsumer in my app with "cargo run" and it properly consumes messages. When doing the same via spawning my app as tokio ask within my integration tests or via std::process::Command with exact the same command the consumer immediately closes.

Starting stream consumer wake loop: 0x14e834800
Shut down stream consumer wake loop: 0x14e834800

[lcmgh]

I found this issue does not occur when my app does not spawn an axum server. super-strange