17_尚硅谷_Kafka_低级API参数设置.avi原创

面，好，那我们来写一下这个DJ边啊，来有一个logo。是有安药不对。好，然后他肯定有一个什么卖方法要执行的吧，无论是消费者要执行的。那这个慢方法在这儿。我们应该有一个什么find领导的方法，对吧，Private。好，然后find领导那个返回值应该是一个broke，对吧？Broke，我们用string string，然后叫find。Leader一样啊，可能这个返回值不对，我们到时候还得调化煤炭，一干到就目前我们能感受到应该是这样的，所以这是第一个。找到。应该就直接找，应该这样说找分区领导。群里的吧。

找分距离的这个方法，然后我们应该还有一个什么方法来干什么。获取数据，刚才提到这核心的两个方法嘛，对吧，获取数据。获取数据的一个方法，OK。然后获取数据，嗯，我们用word里的可以吧，也是因为获取数据之后，我们直接打印一下，就不用，不用它有什么返回值了，打印一下在里面就打印了，就处理掉了，然后这个地方叫get data。改对了啊，这样的核心的两个方法，核心的两个方法OK，然后我们需要考虑的是，呃，这个东西我们肯定在那个什么卖方法里面调用了来获取数据，或者说你来一个外处是不是循环的去获取数据啊，对吧，循环的获取数据，那我们要想一下我们整个的这个方法呀，也就是说这个类啊。是一个DPI，我里面要干什么事？

根据指定的。然后谁？还有什么奥赛的吧？我们是不是要指定这些东西啊，来获取数据？啊，获取数据啊，获取数据OK，那你这个地方是获取数据，你起码那些参数给他传进去，啊，起码那些参数给他传进去，那好，那我们先定义参数。那除了什么topic of之外，那你想想看，你要连什么consumer，或者说你consumer要生成consumer，然后来连卡卡集群，你必不能少的是什么？卡卡机群那个属性要有吧，你要连哪个卡卡机群对吧，那我们来一个。

一个。这里面放的是一个对。这个叫布斯。这个地方就是什么。卡夫卡集群啊，卡夫卡集群，然后我们把这个葫克斯里边添加东西吧。点爱，然后好多宝102。103104啊，三个东西在添加，好啊，这个broke有了不，有了之后还有什么。就是类似于这个东西要有啊，哎，还有。端口号是不是要有啊。Port等于9092等号定义一下，那除了这个，就是类似于我们上面提到的这个topic主题。

主题是谁主题，那这个地方来一个。Tic，然后等于一个。我们三个呢，因为我们三个呢，是三个分区的数据对吧。然后再来主题partition分区。分区啊，我们要获取什么零号分区的一个数据，对分区应该是一个特类型的对吧。PRTITION。等于假如说我们要获取零号分区里面的数据，零号分区数据，那最后还有一个off对吧。ET oket是一个，那我们之前提到的可能是一个long，对吧，如果它的一个类型传进去，类型有变化，我们再把它调整吧，就目前我们能想到的应该是一个浪，是不是好不太懂。

等于假如说我就从从二号这个赛开始消费可以吗？哎，二号可以来消费啊，这些是一个基本的一个。参数啊，我们定义完了，参数定义完了。这个帮我截一下吧。