MAPREDUCE服务 MRS-Kafka Old Consumer API使用样例:功能介绍

时间:2024-06-19 16:04:41

功能介绍

每一个Consumer实例都属于一个Consumer group,每一条消息只会被同一个Consumer group里的一个Consumer实例消费(不同的Consumer group可以同时消费同一条消息)。

下面代码片段在com.huawei.bigdata.kafka.example.Old_Consumer类中,作用在于订阅指定Topic的消息。(注意:旧Consumer API仅支持访问未设置ACL的Topic,安全接口说明见Kafka安全接口介绍

support.huaweicloud.com/devg-mrs/mrs_06_0308.html