我对这个领域还比较陌生,我使用的是高级消费者,使用的是合流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属性,所以我的理解是除非我手动提交它,否则它不会提交偏移量。
如果我遗漏了什么,请给我一些建议。
1条答案
按热度按时间chhqkbe11#
这是预期的行为。您不必提交偏移量来获取新消息。这些都是独立的东西。您可能会先收到50条消息,然后提交偏移量。