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

  • 相关阅读:
    拍照上传图片方向调整
    js 压缩上传图片
    js 各种循环语法
    本地Git仓库对照多个远程仓库
    nrm安装与配置使用
    面试常见问题
    NodeJs文件路径
    vscode添加智能提示(typings)
    前端常用的工具库
    DeepMask学习笔记
  • 原文地址:https://www.cnblogs.com/WardSea/p/7448949.html
Copyright © 2011-2022 走看看