Αυτό το άρθρο είναι ένα άρθρο καθρέφτη της αυτόματης μετάφρασης, κάντε κλικ εδώ για να μεταβείτε στο αρχικό άρθρο.

Architect_Programmer_Code Δίκτυο Γεωργίας»Αρχιτέκτονας › Προγραμματισμός › Ιάβα › Το Spring Boot Kafka επανεκκινείται για να απορρίψει παλιά δεδομένα
Άποψη: 21274|Απάντηση: 1

[Πηγή] Το Spring Boot Kafka επανεκκινείται για να απορρίψει παλιά δεδομένα

[Αντιγραφή συνδέσμου]
Δημοσιεύτηκε στις 2021-11-14 21:42:26 | | |
Απαιτήσεις: Όταν εκκινηθεί η εφαρμογή εκκίνησης ελατηρίου, ορισμένες πληροφορίες διαμόρφωσης θα διαβαστούν από τη βάση δεδομένων ή την προσωρινή μνήμη και το Kafka θα χρησιμοποιηθεί για εγγραφή σε αλλαγές πληροφοριών διαμόρφωσης. Δεδομένου ότι η εφαρμογή ξεκινά με τις πιο πρόσφατες πληροφορίες διαμόρφωσης, τα μηνύματα σχετικά με τις ιστορικές ενημερώσεις διαμόρφωσης Kafka δεν θα έχουν νόημα και εάν χρησιμοποιείτε ιστορικά μηνύματα, θα έχετε προβλήματα.

Μετά την επανεκκίνηση της εφαρμογής Spring Boot, υπάρχει μια ερώτηση σχετικά με τον τρόπο απόρριψης παλαιών δεδομένων για ένα θέμαΤα μηνύματα Κάφκα για την ιστορία αυτού του θέματος δεν λαμβάνονταιΑυτό? Στην πραγματικότητα, αυτό το πρόβλημα μπορεί να λυθεί ρυθμίζοντας τη μετατόπιση εκκίνησης, η οποία επιτρέπει στον συνδρομητή να ορίσει τη μετατόπιση του θέματος στην τελευταία θέση πριν εγγραφεί στο μήνυμα.

Ακόμα κι αν το spring.kafka.consumer.auto-offset-reset έχει οριστεί στο πιο πρόσφατο, ο καταναλωτής θα διαβάσει το μήνυμα από το bit σημαίας όπου αναγνωρίστηκε τελευταία φορά ότι έλαβε το μήνυμα, γεγονός που θα αναγκάσει τον καταναλωτή να διαβάσει μεγάλο αριθμό μηνυμάτων μετά την επανεκκίνηση, εάν ο παραγωγός στείλει μεγάλο αριθμό μηνυμάτων όταν η εφαρμογή είναι κλειστή.

Ο καταναλωτής αναζητά μια συγκεκριμένη μετατόπιση κατά την προετοιμασία, με τον ακόλουθο κώδικα:

(Τέλος)





Προηγούμενος:Το Spring Boot ορίζει δυναμικά το Topic ή το GroupId του Kafka
Επόμενος:Το Linux εξετάζει την έξοδο καταγραφής της υπηρεσίας Systemd

σχετικές αναρτήσεις
 Σπιτονοικοκύρης| Δημοσιεύτηκε στις 2021-11-15 10:37:05 |
Το Spring Boot ορίζει δυναμικά το Topic ή το GroupId του Kafka
https://www.itsvse.com/thread-10152-1-1.html

Κάτω από το CentOS 7, ο Κάφκα συχνά κλείνει λύσεις
https://www.itsvse.com/thread-10090-1-1.html

Η τιμή auto.offset.reset του Κάφκα εξηγείται λεπτομερώς
https://www.itsvse.com/thread-10017-1-1.html

Το σύστημα Kafka Windows θα κλείσει αφού εκτελεστεί για κάποιο χρονικό διάστημα
https://www.itsvse.com/thread-9984-1-1.html

ΣΦΑΛΜΑ Windows Kafka Απέτυχε η εκκαθάριση του αρχείου καταγραφής για __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Ο Kafka διαμορφώνει την απομακρυσμένη παρακολούθηση JMX
https://www.itsvse.com/thread-9968-1-1.html

Λεπτομερής επεξήγηση των παραμέτρων διαμόρφωσης Kafka
https://www.itsvse.com/thread-9965-1-1.html

Ο Κάφκα ρυθμίζει χειροκίνητα τη μετατόπιση μετατόπισης
https://www.itsvse.com/thread-9641-1-1.html

Λειτουργίες Kafka για ουρές μηνυμάτων .NET/C# [με πηγαίο κώδικα]
https://www.itsvse.com/thread-9619-1-1.html
Αποκήρυξη:
Όλο το λογισμικό, το υλικό προγραμματισμού ή τα άρθρα που δημοσιεύονται από το Code Farmer Network προορίζονται μόνο για μαθησιακούς και ερευνητικούς σκοπούς. Το παραπάνω περιεχόμενο δεν θα χρησιμοποιηθεί για εμπορικούς ή παράνομους σκοπούς, άλλως οι χρήστες θα υποστούν όλες τις συνέπειες. Οι πληροφορίες σε αυτόν τον ιστότοπο προέρχονται από το Διαδίκτυο και οι διαφορές πνευματικών δικαιωμάτων δεν έχουν καμία σχέση με αυτόν τον ιστότοπο. Πρέπει να διαγράψετε εντελώς το παραπάνω περιεχόμενο από τον υπολογιστή σας εντός 24 ωρών από τη λήψη. Εάν σας αρέσει το πρόγραμμα, υποστηρίξτε γνήσιο λογισμικό, αγοράστε εγγραφή και λάβετε καλύτερες γνήσιες υπηρεσίες. Εάν υπάρχει οποιαδήποτε παραβίαση, επικοινωνήστε μαζί μας μέσω email.
Mail To:help@itsvse.com