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

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

[Πηγή] Το Spring Boot ορίζει δυναμικά το Topic ή το GroupId του Kafka

[Αντιγραφή συνδέσμου]
Δημοσιεύτηκε στις 14/11/2021 8:03:45 μ.μ. | | | |
Κατά την ανάπτυξη μικροϋπηρεσιών σε ένα σύμπλεγμα, εάν θέλουμε να εκδώσουμε εντολές σε όλες τις εφαρμογές, μπορούμε να εγγραφούμε τις εφαρμογές σε θέματα Kafka, αλλά πρέπει να σημειωθεί ότι πρέπει να οριστούν διαφορετικά groupID για να λαμβάνεται το ίδιο θέμα από όλες τις εφαρμογές.

Χρησιμοποιήστε το docker για να δημιουργήσετε μια εφαρμογή Kafka με τις ακόλουθες εντολές:

Σημείωση: Αντικαταστήστε το 192.168.1.166 με την πραγματική σας διεύθυνση IP

pom.xml Παρουσιάστε το πακέτο ελατηρίου-κάφκα ως εξής:


Για να προσαρμόσετε τη διαμόρφωση καταναλωτή Kafka, δημιουργήστε ένα νέο αρχείο KafkaConsumer ως εξής:


Δημιουργήστε ένα νέο ConfigConsumer καταναλωτή, το οποίο έχει την προεπιλεγμένη ρύθμιση παραμέτρων: topic:defaultTopic,groupid:defaultGroupId και ο κώδικας είναι ο εξής:

application.properties για να διαμορφώσετε τη διεύθυνση του Κάφκα:


Για να ξεκινήσετε ένα έργο, η συνδρομή εφαρμογής είναι η προεπιλεγμένη ρύθμιση παραμέτρων, ως εξής:



Το KafkaMessageListenerContainer κληρονομεί την αφηρημένη κλάση AbstractMessageListenerContainer και η μέθοδος createSimpleLoggingConsumerRebalanceListener εξάγει το groupid και το θέμα του καταναλωτή, το διαμέρισμα.

2021-11-14 19:44:26.689 ΠΛΗΡΟΦΟΡΊΕΣ 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned: [defaultTopic-0]
Ορίστε δυναμικά το θέμα και το groupid και η εντολή έναρξης έργου είναι η εξής:



Το θέμα έχει οριστεί σε a1 και το groupid είναι itsvse.com

2021-11-14 19:46:25.330 ΠΛΗΡΟΦΟΡΊΕΣ 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: κατατμήσεις που έχουν εκχωρηθεί: [a1-0]
Το ελατήριο παρακάμπτει την προεπιλεγμένη διαμόρφωση μέσα στο πακέτο jar
https://www.itsvse.com/thread-10129-1-1.html

(Τέλος)





Προηγούμενος:Αργά ερωτήματα για βελτιστοποίηση απόδοσης MySQL
Επόμενος:Το Spring Boot Kafka επανεκκινείται για να απορρίψει παλιά δεδομένα

σχετικές αναρτήσεις
Αποκήρυξη:
Όλο το λογισμικό, το υλικό προγραμματισμού ή τα άρθρα που δημοσιεύονται από το Code Farmer Network προορίζονται μόνο για μαθησιακούς και ερευνητικούς σκοπούς. Το παραπάνω περιεχόμενο δεν θα χρησιμοποιηθεί για εμπορικούς ή παράνομους σκοπούς, άλλως οι χρήστες θα υποστούν όλες τις συνέπειες. Οι πληροφορίες σε αυτόν τον ιστότοπο προέρχονται από το Διαδίκτυο και οι διαφορές πνευματικών δικαιωμάτων δεν έχουν καμία σχέση με αυτόν τον ιστότοπο. Πρέπει να διαγράψετε εντελώς το παραπάνω περιεχόμενο από τον υπολογιστή σας εντός 24 ωρών από τη λήψη. Εάν σας αρέσει το πρόγραμμα, υποστηρίξτε γνήσιο λογισμικό, αγοράστε εγγραφή και λάβετε καλύτερες γνήσιες υπηρεσίες. Εάν υπάρχει οποιαδήποτε παραβίαση, επικοινωνήστε μαζί μας μέσω email.
Mail To:help@itsvse.com