lorsque le nombre de messages atteint la taille maximale de retention.bytes, le kafka supprimera les messages, le décalage sera remis à zéro?

Question

Je suis nouveau à kafka, quand nous utilisons kafka, nous pouvons définir la retention.bytes. disons que nous mettons à 1 Go, si la quantité de message atteint 1 Go, kafka va supprimer les messages.Je veux demander que le décalage sera remis à zéro? deuxième, le consommateur set auto.offset.reset au plus grand, après kafka supprimer les messages, quel décalage le consommateur va commencer?

Answer 1

Pour votre question # 1, en respectant les règles basées sur la taille et sur la durée, le journal peut être déplacé vers un nouveau segment de journal vide. Le décalage de début du nouveau fichier de segment de journalisation correspond au décalage du message suivant qui sera ajouté au journal.

Pour votre question 2, cela dépend. Si le décalage suivi par le consommateur est hors plage en raison de la suppression du message, il sera réinitialisé au décalage le plus important.