kafka旧低级消费API

半兽人 发表于: 2016-05-23   最后更新时间: 2016-10-26  
  •   1 订阅,2934 游览

2.2.2 低级消费 API


class kafka.javaapi.consumer.SimpleConsumer {
  /**
   *  Fetch a set of messages from a topic.
   *
   *  @param request specifies the topic name, topic partition, starting byte offset, maximum bytes to be fetched.
   *  @return a set of fetched messages
   */
  public FetchResponse fetch(kafka.javaapi.FetchRequest request);

  /**
   *  Fetch metadata for a sequence of topics.
   *
   *  @param request specifies the versionId, clientId, sequence of topics.
   *  @return metadata for each topic in the request.
   */
  public kafka.javaapi.TopicMetadataResponse send(kafka.javaapi.TopicMetadataRequest request);

  /**
   *  Get a list of valid offsets (up to maxSize) before the given time.
   *
   *  @param request a [[kafka.javaapi.OffsetRequest]] object.
   *  @return a [[kafka.javaapi.OffsetResponse]] object.
   */
  public kafak.javaapi.OffsetResponse getOffsetsBefore(OffsetRequest request);

  /**
   * Close the SimpleConsumer.
   */
  public void close();
}

对于大多数的应用,高层次的消费API是不够好的,但是一些应用需要的功能没有暴露在高层次的消费者(例如,重启消费者时,设置初始偏移量)。

这时可以使用我们低层次的SimpleCosumer Api。这个逻辑比较复杂一点,点击 这里 ,查看例子。







发表于: 1年前   最后更新时间: 1年前   游览量:2934
上一条: kafka消息格式
下一条: kafka消费者高级实例

评论…


  • 评论…
    • in this conversation
      提问