auto.commit.enable属性预期不起作用

dced5bon  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(407)

我对这个领域还比较陌生,我使用的是高级消费者,使用的是合流api,并运行curl和postman
使用以下步骤:
1) 创建消费者组:发布http://hostname/consumers/test

{
"name": "offset_test_instance4", 
"format": "json", 
"auto.offset.reset": "earliest",
"auto.commit.enable": "false"
}

2) 使用下面的api:post分配分区http://hostname/consumers/test/instances/offset_test_instance4/assignments

{
  "partitions": [
    {
      "topic": "ids_mps_channel_permissions",
      "partition": 2
    }
  ]
}

3) 阅读内容:获取http://hostname/consumers/test/instances/offset_test_instance4/records?timeout=5000&max_bytes=16777216
我从上面的get请求得到响应。
但当我再次击球时,它给了我新的偏移量,虽然我没有做出任何偏移量,但偏移量仍在不断增加。
因为我已经禁用了auto-commit属性,所以我的理解是除非我手动提交它,否则它不会提交偏移量。
如果我遗漏了什么,请给我一些建议。

chhqkbe1

chhqkbe11#

这是预期的行为。您不必提交偏移量来获取新消息。这些都是独立的东西。您可能会先收到50条消息,然后提交偏移量。

相关问题