*将以下数据按照相同品牌的放入一个分区中,然后写一个消费者只消费改分区中的数据,进行验证。
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;
imp