消费组

在MapReduce中，要消费Kafka数据并创建Kafka消费组，首先需要配置Kafka消费者相关参数，然后创建一个Kafka消费者实例，指定消费组ID和主题，最后调用poll方法获取数据并进行相应的处理。