2017-07-12 1 views
0

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.

Répondre

0

C'est le comportement attendu. Vous n'avez pas besoin de valider un décalage pour obtenir de nouveaux messages. Ce sont des choses indépendantes. Vous pouvez d'abord recevoir 50 messages, puis valider votre décalage.