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

时间:2024-11-25 19:32:58

功能介绍

下面代码片段在com.huawei.bigdata.kafka.example.SimpleConsumerDemo类中,用于实现使用新SimpleConsumer API订阅Topic,并进行消息消费。(注意:SimpleConsumer API仅支持访问未设置ACL的Topic,安全接口说明见Kafka安全接口介绍

SimpleConsumer API属于lowlevel的Consumer API需要访问zookeeper元数据,管理消费Topic队列的offset,一般情况不推荐使用。

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