菜单 学习猿地 - LMONKEY

VIP

开通学习猿地VIP

尊享10项VIP特权 持续新增

知识通关挑战

打卡带练!告别无效练习

接私单赚外块

VIP优先接,累计金额超百万

学习猿地私房课免费学

大厂实战课仅对VIP开放

你的一对一导师

每月可免费咨询大牛30次

领取更多软件工程师实用特权

入驻
441
0

New API

原创
05/13 14:22
阅读数 59147

New API

Producer

》增加发送回调

》重构Partition

统一High Level API与Low Level API

》从kafka.consumerkafka.javaapikafka.clients.consumer(Kafka将所有的相关类都放在这个包中)

subscribe动态rebalancesubscribe接口对应High Level APIvs assign手动分配(assign接口对应Low Level API

》将offset存于KafkaZookeeper以外

ConsumerRebalanceListener(之前只能通过数据来观察rebalance)

》控制消费位置(我们可以控制数据从任何位置开始消费,虽然Low Level API也可以指定消费位置,但是它再一次消费数据时,要指定从上次消费完的位置开始)

》消费流程控制(可以暂停对某个Partiton消费)

》消费流畅控制

 

也就说,New API将原来的High Level API Low Level API里面所有的类归并到kafka.clients.consumer,这个包有SubscribeAssign2个接口分别对应这原来的High Level API Low Level API

 

Subscribe

》自动Rebalance

》自动分配PartitonConsumer

》使用subscribe接口,并可注册ConsumerRebalanceListener

Assign

》使用Assign接口

》指定目标Partition

发表评论

0/200
441 点赞
0 评论
收藏
为你推荐 换一批