Refaktorisierung für Tests - KafkaConsumer als eigenständige Bean