Cet article est un article miroir de traduction automatique, veuillez cliquer ici pour accéder à l’article original.

Architect_Programmer_Code Réseau agricole»Architecte › Programmation › Java › Spring Boot Kafka redémarre pour défaire les anciennes données
Vue: 21274|Répondre: 1

[Source] Spring Boot Kafka redémarre pour défaire les anciennes données

[Copié le lien]
Publié le 14-11-2021 à 21:42:26 | | |
Exigences : Lors du lancement de l’application Spring Boot, certaines informations de configuration seront lues depuis la base de données ou le cache, et Kafka sera utilisé pour s’abonner aux modifications des informations de configuration. Comme l’application commence avec les dernières informations de configuration, les messages concernant les mises à jour historiques de Kafka seront dénués de sens, et si vous utilisez des messages historiques, vous aurez des problèmes.

Après le redémarrage de l’application Spring Boot, une question se pose sur la façon d’éliminer les anciennes données sur un sujetLes messages kafka concernant l’histoire de ce sujet ne sont pas reçusCeci? En fait, ce problème peut être résolu en fixant le décalage de départ, ce qui permet à l’abonné de fixer le décalage du sujet à la dernière position avant de s’abonner au message.

Même si spring.kafka.consumer.auto-offset-reset est réglé sur la plus tardive, le consommateur lira le message depuis le bit de flag où il a été accusé de réception pour la dernière fois, ce qui fera que le consommateur lira un grand nombre de messages après un redémarrage si le producteur envoie un grand nombre de messages lorsque l’application est fermée.

Le consommateur recherche un décalage spécifique lors de l’initialisation, avec le code suivant :

(Fin)





Précédent:Spring Boot définit dynamiquement le Topic ou GroupId de Kafka
Prochain:Linux examine la sortie journalière du service Systemd

Articles connexes
 Propriétaire| Publié le 15-11-2021 à 10:37:05 |
Spring Boot définit dynamiquement le Topic ou GroupId de Kafka
https://www.itsvse.com/thread-10152-1-1.html

Sous CentOS 7, Kafka raccroche souvent les solutions
https://www.itsvse.com/thread-10090-1-1.html

La valeur auto.offset.reset de Kafka est expliquée en détail
https://www.itsvse.com/thread-10017-1-1.html

Le système Kafka Windows se bloque après un certain temps d’exécution
https://www.itsvse.com/thread-9984-1-1.html

ERREUR Kafka Windows : Échec à nettoyer le journal pour __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka configure la surveillance à distance JMX
https://www.itsvse.com/thread-9968-1-1.html

Explication détaillée des paramètres de configuration de Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka règle manuellement le décalage
https://www.itsvse.com/thread-9641-1-1.html

Opérations Kafka pour les files d’attente de messages .NET/C# [avec code source]
https://www.itsvse.com/thread-9619-1-1.html
Démenti:
Tous les logiciels, supports de programmation ou articles publiés par Code Farmer Network sont uniquement destinés à l’apprentissage et à la recherche ; Le contenu ci-dessus ne doit pas être utilisé à des fins commerciales ou illégales, sinon les utilisateurs assumeront toutes les conséquences. Les informations sur ce site proviennent d’Internet, et les litiges de droits d’auteur n’ont rien à voir avec ce site. Vous devez supprimer complètement le contenu ci-dessus de votre ordinateur dans les 24 heures suivant le téléchargement. Si vous aimez le programme, merci de soutenir un logiciel authentique, d’acheter l’immatriculation et d’obtenir de meilleurs services authentiques. En cas d’infraction, veuillez nous contacter par e-mail.
Mail To:help@itsvse.com