数据按照相同品牌的放入一个分区中然后写一个消费者只消费改分区中的数据
*将以下数据按照相同品牌的放入一个分区中,然后写一个消费者只消费改分区中的数据,进行验证。 tom,puma,400 jim,nike,1000 susan,nike,1200 lele,adidas,800 hua,nike,1300 jim,puma,500 lele,nike,500 tom,puma,600 lele,nike,700 hua,adidas,1200 分区器 import org.apache.kafka.clients.producer.Partitioner; import org.apache.kafka.common.Cluster; import java.u
下载地址
用户评论