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

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

Πώς να κατεβάσετε το Kafaka

Επίσημη διεύθυνση ιστότοπου
Η τελευταία έκδοση του Kafka είναι αυτή τη στιγμή η 3.7.1

Μπορούμε να δούμε τις πληροφορίες των δύο εκδόσεων παρακάτω; Τι σημαίνει αυτό;

• Scala 2.12 - kafka_2.12-3.7.1.tgz (αύξουσα, sha512)
• Scala 2.13 - kafka_2.13-3.7.1.tgz (αύξουσα, sha512)
  Πρέπει να γνωρίζουμε ότι μια πλήρης παρουσία του Κάφκα περιέχει τουλάχιστον 3 μέρη:
• Παραγωγός
• Μεσίτης
• Παραγωγός-Καταναλωτής
  Οι παραγωγοί και οι καταναλωτές χρησιμοποιούν τη γλώσσα Java και ο Broker τη γλώσσα Scala, έτσι θα καταλάβετε. Το 2.12 και το 2.13 είναι στην πραγματικότητα οι εκδόσεις του Scala και το 3.7.1 είναι ο πραγματικός επίσημος αριθμός έκδοσης του Kafka.

Εγκατάσταση Κάφκα

Πρέπει πρώτα να διασφαλίσουμε ότι ο διακομιστής μας έχει εγκατεστημένο περιβάλλον Java:

java -version

Κατεβάστε το kafka:
Καθορίστε τη διαδρομή όπου την αποθηκεύουμε με -o

wget -O /usr/local/kafka_2.13-3.7.1.tgz https://downloads.apache.org/kafka/3.7.1/kafka_2.13-3.7.1.tgz

Ανοίγω φερμουάρ:

tar -zxvf  kafka_2.13-3.7.1.tgz

Διαμόρφωση και εκκίνηση του Kafka

Συμβουλές
ο ΚάφκαΕίναι ένα κατανεμημένο σύστημα ανταλλαγής μηνυμάτων δημοσίευσης-εγγραφής υψηλής απόδοσης που μπορεί να επεξεργαστεί όλα τα δεδομένα ροής ενεργειών των καταναλωτών στον ιστότοπο.
ο ΚάφκαΣε προηγούμενες εκδόσεις, αν δεν υπήρχεZooKeeper,ο Κάφκαδεν θα λειτουργήσει.
μεταχειρισμένοςκάφκαοι προγραμματιστές θα πρέπει να το γνωρίζουν αυτό κάθε φορά που ξεκινούνκάφκαΚατά το σερβίρισμα είναι απαραίτητο πρώταΖωοφύλακαςΞεκινήστε, μετά ξεκινήστεκάφκα, τα βήματα είναι αρκετά περίπλοκα.
ο ΚάφκαΔημοσιεύτηκε τώρα2.8έκδοση, επιτρέποντας στους χρήστες να χρησιμοποιούν τοZooKeeperτρέχοντας κάτωο Κάφκα, αυτή η έκδοση θα εξαρτηθεί απόZooKeeperΟ ελεγκτής μετατράπηκε σε ένα με βάσηΣχεδία ΚάφκατουQuormΕλεγκτής (λειτουργία KRaft).

Ξεκινήστε μέσω του ZooKeeper

Δείτε το αρχείο ρυθμίσεων:

connect-console-sink.properties
connect-console-source.properties
connect-distributed.properties
connect-file-sink.properties
connect-file-source.properties
connect-log4j.properties
connect-mirror-maker.properties
connect-standalone.properties
consumer.properties
kraft
log4j.properties
producer.properties
server.properties
tools-log4j.properties
trogdor.conf
zookeeper.properties

1: Τροποποίηση της διαμόρφωσης ZooKeeper

vim zookeeper.properties  
## 配置地址用于存放zookeeper数据存储位置，不存在会自动创建
dataDir=/usr/local/kafka_data/zookeeper_data

2: Ξεκινήστε το ZooKeeper
Εισαγάγετε τον κατάλογο κάδου κάφκα:

#启动zookeeper
../bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties 
# 查看zookeeper进程是否启动  
ps -ef | grep zookeeper

3: Ξεκινήστε τον Κάφκα

vim ../config/server.properties  
#修改log.dirs地址
log.dirs=/usr/local/kafka_data/kafka_data
#启动Kafka
../bin/kafka-server-start.sh -daemon ../config/server.properties 
#通过jps命令可以查看是否启动成功，看到下面的结果表示我们的zookeeper和Kafka都启动成功了
[root@qingshan bin]# jps
7297 Jps
1592 QuorumPeerMain
7241 Kafka

Προβολή αρχείου καταγραφής εκκίνησης
Εάν δεν βλέπετε τη διαδικασία Kafka χρησιμοποιώντας την εντολή JPS μετά την εκτέλεση της εντολής εκκίνησης, η εκκίνηση μπορεί να έχει αποτύχει.Μπορείτε να ελέγξετε το αρχείο καταγραφής εκκίνησης κάτω από την αντίστοιχη διαδρομή και να αντικαταστήσετε τη διαδρομή με τη δική σας διαδρομή Κάφκα.
/usr/local/kafka_2.13-3.7.1/bin/hs_err_pid***.log

Εκκίνηση του Kafka σε λειτουργία KRaft

Ανοίξτε τον Κάφκα μαςΔιαμόρφωσηκατάλογο, υπάρχει ένας φάκελος KRaft.
1: Τροποποιήστε μας για να τροποποιήσουμε τη θέση αποθήκευσης δεδομένων

vim config/kraft/server.properties
log.dirs=/usr/local/kafka_data/kafka_KRaft_data

2: Δημιουργήστε ένα μοναδικό αναγνωριστικό για τον κατάλογο αποθήκευσης
Υπάρχει ένα αρχείο kafka-storage.sh στον κατάλογο bin του kafka

./kafka-storage.sh random-uuid 
#结果
bxoRVvPvR0qjT307GQ6Gag

3: Μορφοποιήστε τον κατάλογο αποθήκευσης

# 将上一步生成的唯一ID替换成自己的，启动使用kraft下的配置文件
./kafka-storage.sh  format -t bxoRVvPvR0qjT307GQ6Gag   -c  /usr/local/kafka_2.13-3.7.1/config/kraft/server.properties

Αποτελέσματα των:

4: Ξεκινήστε τον Κάφκα

#执行启动命令。
./kafka-server-start.sh -daemon ../config/kraft/server.properties