Ξεκινώντας με τον Απάτσι Κάφκα
Πριν εγκαταστήσετε το Apache Kafka, πρέπει να έχετε εγκαταστήσει την Java και έναν λογαριασμό χρήστη με δικαιώματα sudo. Επιπλέον, συνιστάται να έχετε μνήμη RAM 2 GB και άνω για τη σωστή λειτουργία του Kafka.
Τα παρακάτω βήματα θα σας καθοδηγήσουν στον τρόπο εγκατάστασης του Apache Kafka.
Εγκατάσταση Java
Απαιτείται Java για την εγκατάσταση του Kafka. Ελέγξτε εάν το Ubuntu σας έχει εγκαταστήσει Java ελέγχοντας την έκδοση χρησιμοποιώντας την ακόλουθη εντολή:
$ Ιάβα --εκδοχή
Εάν δεν είναι εγκατεστημένη η Java, χρησιμοποιήστε τις ακόλουθες εντολές για να εγκαταστήσετε το Java OpenJDK.
$ sudo κατάλληλος εγκαθιστώ προεπιλογή-jdk
Δημιουργία λογαριασμού χρήστη
Με την Java ήδη εγκατεστημένη, δημιουργήστε έναν λογαριασμό χρήστη χωρίς root. Πρέπει επίσης να του δώσουμε κάποια δικαιώματα sudo προσθέτοντας τον χρήστη στην ομάδα sudo χρησιμοποιώντας την ακόλουθη εντολή:
$ sudo adduser linuxhit
$ sudo adduser linuxhit sudo
Συνδεθείτε στον νέο λογαριασμό χρήστη.
Εγκατάσταση του Κάφκα
Πρέπει να κάνετε λήψη του πιο πρόσφατου Apache Kafka από την επίσημη σελίδα λήψης. Κάντε λήψη των δυαδικών αρχείων του χρησιμοποιώντας το wget εντολή όπως φαίνεται παρακάτω:
$ wget https: // downloads.apache.org / κάφκα / 3.2.3 / kafka_2.12-3.2.3.tgz 
Μόλις γίνει λήψη του δυαδικού αρχείου, εξαγάγετε το χρησιμοποιώντας το παίρνει εντολή και μετακινήστε τον εξαγόμενο κατάλογο στο /opt/kafka.
Στη συνέχεια, δημιουργήστε το συστημικά σενάρια για το Ζωολογοφύλακας και το ο Κάφκα υπηρεσίες που βοηθούν στην έναρξη και τη διακοπή των υπηρεσιών.
Χρησιμοποιήστε ένα πρόγραμμα επεξεργασίας της επιλογής για να δημιουργήσετε τα systemd scripts και να επικολλήσετε τα ακόλουθα περιεχόμενα. Ξεκινήστε με το Zookeeper:
$ sudo νανο / και τα λοιπά / systemd / Σύστημα / φύλακας ζωολογικού κήπου.υπηρεσίαΕπικολλήστε το εξής:
[ Μονάδα ]Περιγραφή =Διακομιστής Apache Zookeeper
Τεκμηρίωση =http: // zookeeper.apache.org
Απαιτεί =network.target remote-fs.target
Μετά =network.target remote-fs.target
[ Υπηρεσία ]
Τύπος =απλό
ExecStart = / επιλέγω / κάφκα / αποθήκη / zookeeper-server-start.sh / επιλέγω / κάφκα / config / ζωοφύλακας.ιδιοκτησίες
ExecStop = / επιλέγω / κάφκα / αποθήκη / zookeeper-server-stop.sh
Επανεκκίνηση =ανώμαλο
[ Εγκαθιστώ ]
WantedBy =multi-user.target
Αποθηκεύστε το αρχείο. Δημιουργήστε το αρχείο systemd για το Kafka και επικολλήστε τα ακόλουθα περιεχόμενα:
Κατά την επικόλληση, βεβαιωθείτε ότι έχετε ορίσει τη σωστή διαδρομή για την Java που εγκαταστήσατε στο σύστημά σας.
[ Μονάδα ]Περιγραφή =Διακομιστής Apache Kafka
Τεκμηρίωση =http: // kafka.apache.org / documentation.html
Απαιτεί =zookeeper.service
[ Υπηρεσία ]
Τύπος =απλό
περιβάλλον = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / επιλέγω / κάφκα / αποθήκη / kafka-server-start.sh / επιλέγω / κάφκα / config / διακομιστής.ιδιότητες
ExecStop = / επιλέγω / κάφκα / αποθήκη / kafka-server-stop.sh
Επανεκκίνηση =ανώμαλο
[ Εγκαθιστώ ]
WantedBy =multi-user.target
Μόλις τελειώσετε, εφαρμόστε τις αλλαγές φορτώνοντας ξανά τον δαίμονα systemd:
Στη συνέχεια, ενεργοποιήστε την υπηρεσία Zookeeper και ξεκινήστε την χρησιμοποιώντας τις ακόλουθες εντολές:
$ sudo systemctl εκκίνηση zookeepe < ισχυρός > r ισχυρός >
Πρέπει επίσης να κάνετε το ίδιο για τον Κάφκα:
$ sudo systemctl start kafka
Μόλις ξεκινήσετε τις υπηρεσίες, μπορείτε να επαληθεύσετε την κατάστασή τους πριν δημιουργήσουμε ένα θέμα στον Κάφκα.
Το καλό με τον Κάφκα είναι ότι υπάρχουν πολλά σενάρια που μπορείτε να χρησιμοποιήσετε.
Ας δημιουργήσουμε ένα νέο θέμα με το όνομα linuxhit1 χρησιμοποιώντας το kafka-topics.sh σενάριο με ένα διαμέρισμα και μια αναπαραγωγή. Χρησιμοποιήστε την ακόλουθη εντολή:
$ sudo -σε λινούξιντ / επιλέγω / κάφκα / αποθήκη / kafka-topics.sh --δημιουργώ --bootstrap-server localhost: 9092 --συντελεστής αναπαραγωγής 1 -- χωρίσματα 1 --θέμα linuxhit1 
Σημειώστε ότι το θέμα μας δημιουργήθηκε. Μπορούμε να δούμε το προηγούμενο μήνυμα για να το επιβεβαιώσουμε.
Εναλλακτικά, μπορείτε να απαριθμήσετε τα διαθέσιμα θέματα χρησιμοποιώντας το -λίστα επιλογή στην παρακάτω εντολή. Θα πρέπει να επιστρέψει το θέμα που δημιουργήσαμε:S
$ sudo -σε λινούξιντ / επιλέγω / κάφκα / αποθήκη / kafka-topics.sh --λίστα --bootstrap-server localhost: 9092 
Με τη δημιουργία του θέματος Kafka, μπορείτε να αρχίσετε να γράφετε τα δεδομένα ροών στο Κάφκα-κονσόλα-παραγωγός.sh και ελέγξτε αν αντικατοπτρίζεται στο δικό σας καταναλωτής.χ.
Ανοίξτε το κέλυφός σας και αποκτήστε πρόσβαση στο θέμα που δημιουργήσαμε χρησιμοποιώντας το producer.sh όπως φαίνεται παρακάτω:
$ sudo -σε λινούξιντ / επιλέγω / κάφκα / αποθήκη / kafka-console-producer.sh --κατάλογος μεσίτη localhost: 9092 --θέμα linuxhit1 
Στη συνέχεια, ανοίξτε ένα άλλο κέλυφος και αποκτήστε πρόσβαση στο θέμα του Κάφκα χρησιμοποιώντας τον καταναλωτή.sh.
Με τα δύο κελύφη ανοιχτά, μπορείτε να στείλετε μήνυμα στην κονσόλα παραγωγού. Ό,τι πληκτρολογείτε αντικατοπτρίζεται στην κονσόλα καταναλωτή επιβεβαιώνοντας ότι το Apache Kafka μας είναι σε λειτουργία.
συμπέρασμα
Με αυτόν τον οδηγό, έχετε τώρα όλα τα βήματα που μπορείτε να ακολουθήσετε για να εγκαταστήσετε το Apache Kafka στο Ubuntu 22.04. Ας ελπίσουμε ότι καταφέρατε να ακολουθήσετε κάθε βήμα και να εγκαταστήσετε το Apache Kafka και να δημιουργήσετε θέματα για να εκτελέσετε μια απλή παραγωγή καταναλωτών και παραγωγών. Μπορείτε να εφαρμόσετε το ίδιο σε μεγάλη παραγωγή.