14_尚硅谷_Kafka_自定义分区的生产者.avi原创

好，这是我们测的这个带回调函数的，还有一个。啊，还有什么呢，就是带负加函数的吧，还有一个自定义分区。自定义分区啊，这个东西我们也可以自定义分区，那其实它跟那个map一样，Map是继承一个帕能力对吧，它是实现一个帕提能力来。那这个地方。有一个类叫customer。Customer partition。上，那它实现。爬梯的吧？一号是那个卡不卡客户端报销的啊，而且是生产者报销的吧，因为你这个指定分区不可能说在消费者的指定分区吧啊。实践方法，实践方法，那核心的方法。

就是这个，你看它的一个什么，它就叫partition来返回值是in的，返回成in的，然后还有两个方法。就是说哎，你在过程当中遇到什么资源可以在这关闭一下吧，关闭一下OK，还有看这就是说这个地方啊，可以把那个什么你前面带进来的配置文件全部给读出来，假如说你这个方法里边要用到我们配置文件，是不是可以在这给它读出来呀，哎，这是可以的啊，这是可以的，是这样的可以的配置文件可以用，或者说你要对某些配置文件进行修改，经过这个分区之后，因为它这样的数据。进入赛道方法之后啊，他先经过的是一个分区决定你这个数据啊，要进到。哪个爬里边，所以说这块的时候呢，应该把它配置文件。做一个相应的修改也是可以的，也是可以的，OK，那我们就关注核心的那个什么。塔方法对吧，因为我们这个地方涉及到把那个配置文件什么操作吗。

不涉及了，或者说这个这个方法干什么用啊，更重要的是做这个事来看一下它这个是一个map对吧，就是说你这边做一个private声明，假如说声明一个map，然后叫那个con。卖等于一个，那然后你把这个卖干什么。看卖吧，等于哎。Co等于。然后你在这个里边。是不是可以读一些什么？属性出来啊，哎，可以获取一些属性吗？哎，是做这个用的，就是说你这个分区方法里边可能会用到某些什么配置啊，用到某些配置的时候你再去用啊，这个方法是这样用的。对跟一样，它那个你在深圳那个什么。

Producer生产者的时候，是不是它里面除了全之外还有一个ma呀？你想想想，这个purpose跟那个map有有什么区别吗？都是KB类型的吧，啊，它的这边做了一个转换，左边一个转换，你在前面直接放map进去也是可以的，也是可以的，那我们还是同样的关注这个核心的方法，我们就干什么事呢？这个地方我们不动了，我们就希望刚才看到的数据返回值是什么，三个分区都有啊，现在呢，我们加一个这个分区，自定义分区，让他全部写到。一个分区里边啊，就是零号分区，那个返回零，就是返回到零号分区吧，那你看一下它里面传什么to米K。K的一个自节数组，Y6Y61个自节数组等等这些内容啊，是不是你的分区可以拿K进行什么哈希啊，拿Y6进行哈希啊都可以啊，哎，你只要这些参数都能用上啊，都能用上好，那这个Z是写完了，那接下来我直接运行。

能行吗？你没有关联吧，跟我这个生产者没有关联是不是？那。大家猜一下它应该在哪关联呢？配置同样的是配置啊，在配置里边来看一下这是配置那个对吧，来找一下那个ctrl fl p IO partition。这partition呢，点class吧，part.class哎，这个属性啊，其实你如果说直接把这个复制过去也可以了，是一样的CTRLC。然后在这加一个什么点put，然后这个里边过来了，那它既然是叫什么class，那你这里面应该放的是什么全类名吧，哎，把这个拿过来。看到没？

那这样就把我们自定义的这个分区啊，就放进去了，OK，来再走一下。看到一个返回值有什么不一样吗？什么全都在零号分区了吧，啊全都在零号分区了，OK，那这边的一个打印呢，也就是按013456789排号，因为它的一个分区，他读完整个的一个分区，才能读下一个分区吧，所有的数据都在这一块，所以说这块又有顺又有顺序了。因为是一个分区的数据啊，一个分区的数据是这样的，那你在生产环境当中，你要用到的话，肯定不可能说直接写死到一个分区吧，那这块你要怎么做，你可以拿出这些东西，相应的方法都可以，哈希，然后什么模拟分区数吧，分数这都可以的啊，这都可以的。