Apache Kafka

Δεξί κλικ στο δέντρο ▸ Προσθήκη ▸ Αίτημα Kafka.

Κοινή διαμόρφωση

Πεδίο	Ρόλος
URL	Η λίστα των μεσιτών, χωρισμένη με κόμματα: hote1:9092,hote2:9092 — ολόκληρη η συμβολοσειρά επιλύεται από το Handlebars πριν τεμαχιστεί
Αναγνωριστικό πελάτη	Το clientId που ανακοινώνεται στους μεσίτες
Θέμα	Το θέμα, όποια κι αν είναι η λειτουργία
Λειτουργία	produce, consume ή browse

Ταυτοποίηση

Πεδίο	Τιμές
Μηχανισμός SASL	none, plain, scram-sha-256, scram-sha-512
Χρήστης SASL / Κωδικός πρόσβασης SASL	Ο κωδικός δέχεται τιμή τύπου Μυστικό
TLS	Ενεργοποιείται ανεξάρτητα — ένας μεσίτης σε TLS χωρίς SASL λειτουργεί με τον μηχανισμό none

Λειτουργία produce

Κλειδί, τιμή, κεφαλίδες εγγραφής και, προαιρετικά, διαμέρισμα. Χωρίς ρητό διαμέρισμα, εφαρμόζεται ο προεπιλεγμένος διαμεριστής της βιβλιοθήκης πελάτη. Η απόκριση επιστρέφει τα μεταδεδομένα της εγγραφής που γράφτηκε: θέμα, διαμέρισμα, offset.

Λειτουργία consume

Πεδίο	Ρόλος
Ομάδα	Το groupId του καταναλωτή
Offset εκκίνησης	earliest, latest ή specific
Συγκεκριμένο offset	Μια συμβολοσειρά — τα offsets του Kafka είναι ακέραιοι 64 bit
Διαμερίσματα	Ένα φίλτρο από την πλευρά του πελάτη: η ανάθεση στα διαμερίσματα εξακολουθεί να γίνεται από την ομάδα

Λειτουργία browse

Επιθεωρεί ένα διαμέρισμα χωρίς ομάδα καταναλωτών: το Restorm αντλεί από αυτό έναν περιορισμένο αριθμό μηνυμάτων και έπειτα αποσυνδέεται. Το διαμέρισμα είναι υποχρεωτικό σε αυτή τη λειτουργία.

Είναι το κατάλληλο εργαλείο για να δείτε τι υπάρχει σε ένα θέμα χωρίς να δημιουργήσετε ομάδα ούτε να μετακινήσετε offset.

Μέσα σε ένα σενάριο

• Παραγωγή Kafka — μεμονωμένη ενέργεια, επιστρέφει τα μεταδεδομένα της εγγραφής·
• Κατανάλωση Kafka — εγγράφεται μέσω της ομάδας καταναλωτών και εκπέμπει ένα συμβάν ανά μήνυμα·
• Κλείσιμο σύνδεσης Kafka — σταματά την κατανάλωση.

Δείτε Συνδέσεις και ροές.

Αποσπάσματα κώδικα

Πέντε στόχοι: JavaScript (kafkajs, σε παραγωγή και σε κατανάλωση) και kcat (παραγωγή, κατανάλωση, επιθεώρηση χωρίς ομάδα).