Κοινή χρήση τεχνολογίας

παραγωγός kafka

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

παραγωγός

Οι παραγωγοί είναι υπεύθυνοι για τη δημιουργία μηνυμάτων και στη συνέχεια την παράδοση τους στον Κάφκα.
Εισαγάγετε την περιγραφή της εικόνας εδώ

εξισορρόπηση φορτίου

  1. Στρατηγική δημοσκοπήσεων.
  2. Τυχαία στρατηγική.
  3. Κατακερματισμός σύμφωνα με το κλειδί.

Η προεπιλεγμένη στρατηγική διαμερισμάτων του Kafka: Εάν έχει καθοριστεί το κλειδί, τα μηνύματα με το ίδιο κλειδί θα σταλούν στο ίδιο διαμέρισμα (τα διαμερίσματα έχουν παραγγελθεί εάν το κλειδί δεν έχει καθοριστεί, χρησιμοποιείται η στρατηγική ψηφοφορίας).

Στέλνω ένα μήνυμα

Το acks καθορίζει πόσα αντίγραφα διαμερισμάτων χρειάζεται ο παραγωγός για να λάβει το μήνυμα πριν θεωρήσει ότι το μήνυμα έχει γραφτεί με επιτυχία.

Δεν υπάρχουν πλεονεκτήματα ή μειονεκτήματα μεταξύ των τριών μεθόδων, Αντίθετα, πρέπει να επιλέξετε την κατάλληλη στρατηγική σύμφωνα με τις τοπικές συνθήκες. Υπάρχει μια αντιστάθμιση μεταξύ απόδοσης και αξιοπιστίας.

Υπάρχουν 3 τρόποι αποστολής μηνυμάτων:

Στείλτε και ξεχάστε.

ακίδες = 0.
Ο παραγωγός δεν περιμένει καμία απάντηση από τον μεσίτη μετά την αποστολή του μηνύματος. Στις περισσότερες περιπτώσεις, τα μηνύματα μπορούν να παραδοθούν με επιτυχία επειδή ο Κάφκα είναι πολύ διαθέσιμος και ο παραγωγός έχει έναν μηχανισμό για να προσπαθεί αυτόματα να ξαναστείλει. Ωστόσο, εάν παρουσιαστεί σφάλμα χωρίς δυνατότητα επανάληψης ή λήξη χρόνου, το μήνυμα θα χαθεί και η εφαρμογή δεν θα λάβει καμία πληροφορία ή εξαίρεση.
Κάτω από το ίδιο περιβάλλον διαμόρφωσης, η ρύθμιση των acks στο 0 μπορεί να επιτύχει τη μέγιστη απόδοση.

Αποστολή ασύγχρονα

acks=1, προεπιλεγμένη τιμή.
Αφού ο παραγωγός στείλει το μήνυμα, εφόσον το αρχηγό αντίγραφο του διαμερίσματος γράψει με επιτυχία το μήνυμα, θα λάβει μια επιτυχημένη απάντηση από τον διακομιστή.

  • Εάν το μήνυμα δεν μπορεί να γραφτεί στο αρχηγό αντίγραφο, όπως όταν το αντίγραφο του αρχηγού διακόπτεται και επιλέγεται ξανά ένα νέο αντίγραφο αρχηγού, ο παραγωγός θα λάβει μια απάντηση σφάλματος Προκειμένου να αποφευχθεί η απώλεια του μηνύματος, ο παραγωγός μπορεί να επιλέξει να το στείλει ξανά μήνυμα.
  • Εάν ένα μήνυμα γραφτεί στο αρχηγό αντίγραφο και μια επιτυχής απάντηση επιστραφεί στον παραγωγό και το αντίγραφο αρχηγού διακοπεί πριν τραβηχτεί από άλλα αντίγραφα ακολούθων, το μήνυμα θα εξακολουθήσει να χαθεί αυτήν τη στιγμή επειδή το αντίστοιχο μήνυμα δεν υπάρχει στο αντίγραφο του νεοεκλεγμένου αρχηγού.
    acks έχει οριστεί στο 1, το οποίο είναι ένας συμβιβασμός μεταξύ της αξιοπιστίας του μηνύματος και της απόδοσης.
Αποστολή συγχρονισμένη

acks = -1 ή acks = όλα.
Αφού ο παραγωγός στείλει το μήνυμα, πρέπει να περιμένει όλα τα αντίγραφα στο ISR να γράψουν με επιτυχία το μήνυμα για να λάβει μια επιτυχή απάντηση από τον διακομιστή.
Κάτω από το ίδιο περιβάλλον διαμόρφωσης, η ρύθμιση των acks σε -1 (όλα) μπορεί να επιτύχει την ισχυρότερη αξιοπιστία. Αυτό όμως δεν σημαίνει ότι το μήνυμα πρέπει να είναι αξιόπιστο, γιατί μπορεί να υπάρχει μόνο ένα αρχηγό αντίγραφο στο ISR, το οποίο εκφυλίζεται στην κατάσταση acks=1.