Refaktorisierung für Tests - Start des EndlessConsumer in ApplicationRunner