MassTransit 中不存在的主题的例外情况

Question

当 Kafka 中的主题不存在并且使用 TopicEndpoint 方法为其完成了端点配置时，它会抛出异常： Confluent.Kafka.ConsumeException: Broker: Unknown topic or partition。 创建主题后，该异常不再发生。如何为使用TopicEndpoint 方法配置的端点设置自动创建主题？

Answer 1

目前不支持自动创建主题，根据一些使用 Kafka 的企业的经验，他们也不推荐它。通常，它是经过管理的，以便可以将适当的分区和所有权应用于主题（而不仅仅是猜测）。

事实上，我什至不确定 Kafka 消费者（使用 Confluent 客户端）是否可以自动创建主题。架构注册表等方面也需要考虑在内。

我对讨论持开放态度，但做出的选择是基于采访使用 Kafka 的团队，他们说他们通常不允许自动创建主题。