【问题标题】:How kafka high /low level consumer API fetch the messages from the broker?kafka 高/低级消费者 API 如何从代理获取消息?
【发布时间】:2017-05-15 12:33:26
【问题描述】:

据我所知,kafka 消费者只能使用 API poll() 从代理中提取消息,但是我们知道我们也可以使用 kafka 高级/低级消费者 API 从代理中获取消息,那么什么是kafka 高/低级消费者 API 和 API poll() 之间的关系?高/低级消费者API调用里面的poll()?

【问题讨论】:

    标签: apache-kafka kafka-consumer-api


    【解决方案1】:

    High/Low 级别的消费者是所谓的老消费者,由 Scala 实现。带有 poll API 的消费者是新的消费者,完全由 Java 编写。

    旧消费者将很快被弃用,现在推荐新消费者。

    【讨论】:

    • 谢谢你的澄清,谢谢:-)
    • @Jason bukeqi~~
    • 顺便说一句,对于像下面这样的旧高级消费者,它如何从代理获取消息,它不使用 poll() 来获取消息吗? cwiki.apache.org/confluence/display/KAFKA/…
    • 很难用几句话来解释整个事情。简而言之,两个消费者都尊重客户端向代理发送 FETCH 请求并且代理响应这些请求的方式。但是,旧的消费者使用多个线程来执行这些操作。
    猜你喜欢
    • 2016-03-11
    • 1970-01-01
    • 2015-06-05
    • 2016-10-16
    • 2016-09-01
    • 2017-07-10
    • 2014-03-12
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多