auto.commit.enable 属性无法正常工作

Question

我对这个领域比较陌生，我正在使用高级消费者并使用 confluent api 并通过 curl 和 postman 运行

使用以下步骤：

1) 创建消费组 :POST 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) 读取内容：GET http://hostname/consumers/test/instances/offset_test_instance4/records?timeout=5000&max_bytes=16777216

我正在从上面的获取请求中获取响应。

但是当我再次击球时，尽管我没有提交任何偏移量，但它给了我新的偏移量，但偏移量仍在继续增加。

由于我禁用了自动提交属性，所以我的理解是在我手动提交之前它不会提交偏移量。

如果我遗漏了什么，请指教。

Answer 1

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