zoukankan      html  css  js  c++  java
  • New API

    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

  • 相关阅读:
    模板类 & 虚函数
    Page Color (页面着色)
    修改静态库
    ElementUI 时间选择器
    自定义export
    vue组件
    ElementUI 表格
    ElementUI 分页
    数组方法分类
    Vue过滤数组副本
  • 原文地址:https://www.cnblogs.com/WardSea/p/7448949.html
Copyright © 2011-2022 走看看