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

  • 相关阅读:
    抽象工厂模式
    工厂方法模式
    单例模式
    适配器模式
    外观模式
    简单工厂模式
    设计模式开篇闲谈
    android ui更新
    android获取Context
    android 事件绑定
  • 原文地址:https://www.cnblogs.com/WardSea/p/7448949.html
Copyright © 2011-2022 走看看