Ce qui détermine Kafka à la consommation de décalage?

Je suis relativement nouvelle de Kafka. J'ai fait un peu d'expérimenter avec elle, mais quelques choses ne sont pas claires pour moi au sujet de la consommation de l'offset. De ce que j'ai entendu jusqu'à présent, lorsqu'un consommateur commence, le décalage, il va commencer la lecture est déterminé par le paramètre de configuration auto.offset.reset (corrigez-moi si je me trompe).

Maintenant dire par exemple qu'il y a 10 messages (décalages de 0 à 9) dans le sujet, et un consommateur qui s'est passé à consommer 5 d'entre eux avant il est allé vers le bas (ou avant j'ai tué le consommateur). Puis dire que j'ai redémarrer le processus de consommation. Mes questions sont les suivantes:

  1. Si le auto.offset.reset est fixé à smallest, est toujours, il va commencer à consommer de l'offset 0 ?

  2. Si le auto.offset.reset est fixé à largest, est-ce que ça va commencer à consommer de décalage de 5 ?

  3. Est le comportement à l'égard de ce genre de scénario toujours déterministe ?

S'il vous plaît n'hésitez pas à commenter si quelque chose dans ma question n'est pas claire. Merci à l'avance.

InformationsquelleAutor Asif Iqbal | 2015-09-04