自动创建Consumer Group适用于测试场景或临时迁移场景。在生产环境长期开启自动创建Consumer Group,可能会因为客户端使用不当而出现资源随意创建的问题。在生产环境,建议您尽可能通过消息队列Kafka版控制台或OpenAPI来管理Consumer Group。
前提条件
背景信息
调用Consumer API自动创建Consumer Group
注意
- 自动创建的Consumer Group的名称需遵循消息队列Kafka版的Consumer Group命名规则,否则Consumer Group不会被创建。
- 自动创建的Consumer Group的数量需遵循消息队列Kafka版实例的规格限制,否则Consumer Group不会被创建。
- 自动创建的Consumer Group不受消息队列Kafka版控制台管控,因此消息队列Kafka版控制台的Consumer Group管理页面不会显示自动创建的Consumer Group。
为消息队列Kafka版实例开启自动创建Consumer Group后,您可以通过调用Consumer API来自动创建Consumer Group。
示例代码如下:
props.put(ConsumerConfig.GROUP_ID_CONFIG, "newConsumerGroup");
consumer.subscribe(Collections.singletonList("newTopicName"));
// 如果该Consumer Group不存在,则自动创建该Consumer Group。
consumer.poll(Duration.ofSeconds(1));
在文档使用中是否遇到以下问题
更多建议
匿名提交