Как бы ты влез в жизненный цикл Kafka Listener — через KafkaListenerEndpointRegistry или явный polling через KafkaConsumer?