29_尚硅谷_Kafka案例_API生产者分区策略测试

好，刚才呢，我们是通过这个回调函数测了一下一个问题就是说呃，这个东西到底是从零开始，从一开始，其实我们看到从零开始吧，啊，从零开始保存的这个可以证明，然后接下来还有一个问题，呃，这个produce record，这除了这个。就是当前send。是不是有两个重载的方法，一个不带回调，一个带回调对吧？好，那无论哪一种当中，你第一个参数是不是一个producer recorder，这个recorder这个东西，它是不是有很多的一个什么。重载的方法呀。对吧，啊，就重载的方法，好，那我们现在用一下这个内容。用一下它，哎，这个地方怎么变成那个颜色，聘到屁了。好指定topic，然后指定分区对吧，然后只给他一个K，那我们加一下这个名额就在前面呢，我们要加一个什么。

在哪啊，在topic后面加个分区加一个P啊。这加一个分区，假如说我想都把它放到哪。零号分区，然后KK我们怎么放一下呢。都给他都会应该有一个什么。双引号。啊，双引号都给一个I硅谷啊，其实案例要个提示，就是这边它告诉你当前参数是什么对吧？啊，你看这个也就知道了，OK，那我们走一下那回调函数返回过来的。那还会有二一吗？不会的吧，啊，不可能有二一了，对吧，因为我们指定了将这个数据发到哪零二分七对吧？啊全部都在什么。零号分区啊，零号分区，然后接下来还有一个问题，来看一下这个数据。消费到的一个内容还是什么。那个。啊。这个东西。

K，我们指定的是什么？硅谷那有同学可能在想，那是不是消费者就是说你这个东西压根就没存进去呢，对吧，等我到消费者的时候，我们来看啊，这个K呢是可以消费到的，但是控制台的消费者，因为控制台这个东西是不是一个命令啊。一个命令，它最终调的还是API网啊，它触发的还是一个消费者的一个操作，那个里面呢，只打印什么。Value啊，只打印VALUE6啊，只打value是这个意思啊，所以呢，你在这只能看到value，不是说你这只能看到VALUE6，说那个卡巴这块呢，它不存啊，不存K啊，那接下来还有一个，它还有个重载的方法，是不是你不指定这个内容啊。不指定这个内容，然后指定什么。KVKV，呃，指定KV，我想想看这个东西咱们应该怎么设计一下，让它按照哈希值来。那怎么设计呢？嗯，我想用ABC这样这样，嗯，其实这块。

这样来做一下。在这我一个list。List这里面呢，放一个那个啊啊这个呢是一个list啊，是一个list，这是额外加的点啊，里面爱的A。B。CAABC对吧，呃，加一个ABC，然后这个里边我们这个K啊，不要这个内容用什么。嗯，List。呃。点get这个index，咱们写，咱们怎么写一下。这个应该是从零开始的，那。我。这样是不是01012去取啊，那也就是说ABCAABC吧啊让它变化是做这个事，做这个事要如果你写死了，不一个分区了，对吧，我们看看这个效果，但这个东西呢，12345，但是他又是批量发送的。

这是批量发送的120没有是吗？ABC啊，咱们用的是一个string string，也就是说它这个值出来没有那个V3不会等于零吗？I模拟三，那这样如果说给他写死，那应该是什么情况？如果给写死，我们就看给写死这种情况。进到一个分区吧，啊进到一个分区，因为它是按照K的哈一值来了，刚才那个是没取出来吗？还是什么情况没取到一个，其中只只有两个是吧，零没有零没有，那不管就这样，其实你直接写死，那这个既然是一个固定值，那你怎么哈希值模三它出来结果是一样的吧，也就按照硅谷模，它一直模拟三之后应该取得几。

得一对吧，啊，得一是这个内容啊，得一是这样的啊，这是我们看到的，因为它有多个重载的一个方法，但是之前我们没有测，因为之前这个地方不好测，因为之前你测了。你怎么确定发到哪个分区啊？确定不了吧，啊，正好这块有回调函数，我们可以在回调函数里面去打印它，对吗。分区啊，我们通过这种方式可以来看一下啊，可以看一下啊，这边呢有几个重戴方法，然后看到这边呢，有一个什么。你可以指定分区，是不是确定的分区对吧，指定到哪到哪，如果没指定，你指定到K的话。那按照K等于什么，它一直来到，它一直来到那家，如果说你都没有指定，那我就用什么。轮询啊，那我就轮询是这个意思啊，这个呢，是我们所说的这个点，关于它当中的其他的两个就是，呃，其他两个重载的方法啊，重载的方法是这个意思。