Kafka位移主题

上一节我们介绍了位移提交，消费的位移如何保存时其中提到了位移主题__consumer_offsets这个是Kafka的内部主题，还有一个内部主题 __transaction_state(事务有关)，后面我们再介绍，内部主题由Kafka自身进行维护，本节我们将揭开内部主题__consumer_offsets神秘的面纱。

more >>

展开全文 >>

Kafka位移提交

Kafka的消费模式都是手动拉取，没有RoceketMQ的推拉模式，这就需要我们知道每次消费后消息的消费位移就需要我们自己来维护，当然Kafka为了解放开发人员同时提供了自动提交方式，手动提交分为异步和同步提交位移，本章我们就重点分析各种方式的利弊。

more >>

展开全文 >>

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true