我需要在运行时使用Kafka IAdminClient或Confluent Kafka暴露的任何其他接口创建消费者组。我明白，通过将allow.auto.create.topics设置为true可以解决我的需求。
在我的情况下，我连接到事件中心。在Event hub中，我们需要显式地创建一个消费者组。如果在使用消息时没有指定消费者组，则使用$Default消费者组。如果我提供的消费者组在event hub中不存在，那么它会抛出一个错误。
你们能把我带到正确的道路上吗?
AdminClient不负责组的创建。要做到这一点，唯一的方法是为消费者订阅具有GroupId配置的主题。
如果你只想初始化一个空的组，订阅一个消费者，在它轮询时寻找你希望它开始的偏移量，然后为这个组提交偏移量。所有这些都是通过一个Consumer实例完成的。
在Event hub中我们需要显式地创建一个消费者组。
那么你需要一个EventHub API客户端来执行这个操作，因为Kafka不关心现有的组;如果不存在，则创建一个。