Я использую фреймворк для микронавтов. У меня есть некоторый оставшийся (потоковый) API, и мне нужно создать KafkaConsumer, когда кто-то вызывает конкретную конечную точку (/myendpoint/topic/group/...).
Я не знаю, какую тему слушать до вызова этой конечной точки, поэтому яне может создать потребителя с @KafkaListener и @Topic.
Есть ли способ сделать это, или мне нужно реализовать что-то вроде io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor самостоятельно?