Je suis relativement nouveau dans ce domaine, j'utilise les consommateurs de haut niveau et en utilisant api confluentes et en cours d'exécution par boucle et postierpropriété auto.commit.enable ne travaillant pas prévu
Utilisation étapes suivantes:
1) Créer un groupe de consommateurs: POST http://hostname/consumers/test
{
"name": "offset_test_instance4",
"format": "json",
"auto.offset.reset": "earliest",
"auto.commit.enable": "false"
}
2) Affectez les partitions en utilisant l'api ci-dessous: POST http://hostname/consumers/test/instances/offset_test_instance4/assignments
{
"partitions": [
{
"topic": "ids_mps_channel_permissions",
"partition": 2
}
]
}
3) Lecture du contenu: GET http://hostname/consumers/test/instances/offset_test_instance4/records?timeout=5000&max_bytes=16777216
i am Getting responses from above get request.
But when i am hitting again its giving me new offset though i have not committed any offset still offsets is keep on increasing.
Depuis que j'ai désactivé l'auto commettras propriété, donc je crois comprendre qu'il ne commettra pas le décalage jusqu'à ce que je commets manuellement.
S'il vous plaît des conseils si quelque chose me manque.