Исключение при попытке подписаться на тему Kafka до ее создания ⇐ C#

[Anonymous]

Я пытаюсь подписаться на тему с подстановочными знаками, например «^my-topic-name-*». На момент подписки данных тем еще не существует. Результатом является следующее исключение:

Код: Выделить всё

   Confluent.Kafka.ConsumeException: Subscribed topic not available: ^my-topic-name-*: Broker: Unknown topic or partition
at Confluent.Kafka.Consumer`2.Consume(Int32 millisecondsTimeout)
at Confluent.Kafka.Consumer`2.Consume(CancellationToken cancellationToken)

Обратите внимание, что исключение происходит только тогда, когда я действительно пытаюсь потреблять:

Код: Выделить всё

var consumeResult = _kafkaConsumer.Consume(stoppingToken);

К сожалению, я не могу определить, ожидаемо ли это поведение или я делаю что-то неправильно. Короче говоря, как я могу подписаться на темы с подстановочными знаками и использовать их до их создания?

Подробнее здесь: https://stackoverflow.com/questions/790 ... is-created