Berbagi teknologi

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

Cara mengunduh Kafaka

Alamat situs web resmi
Versi terbaru Kafka saat ini adalah 3.7.1

Bisakah kita melihat informasi dua versi di bawah ini? Maksudnya itu apa?

• Skala 2.12 - kafka_2.12-3.7.1.tgz (naik, sha512)
• Skala 2.13 - kafka_2.13-3.7.1.tgz (asc, sha512)
  Perlu kita ketahui bahwa instance Kafka yang lengkap berisi setidaknya 3 bagian:
• Produsen
• Makelar
• Produsen-Konsumen
  Produsen dan konsumen menggunakan bahasa Java, dan Broker menggunakan bahasa Scala, sehingga Anda akan mengerti. 2.12 dan 2.13 sebenarnya adalah versi Scala, dan 3.7.1 adalah nomor versi resmi Kafka yang sebenarnya.

Instalasi Kafka

Pertama-tama kita perlu memastikan bahwa server kita telah menginstal lingkungan Java:

java -version

Unduh kafka:
Tentukan jalur tempat kita menyimpannya dengan -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

Buka zip:

tar -zxvf  kafka_2.13-3.7.1.tgz

Konfigurasi dan startup Kafka

Kiat
KafkaIni adalah sistem pesan terbitkan-langganan terdistribusi dengan throughput tinggi yang dapat memproses semua data aliran tindakan konsumen di situs web.
KafkaDi versi sebelumnya, jika tidak adaPenjaga kebun binatang,Kafkatidak akan berfungsi.
digunakanKafkapengembang harus mengetahuinya setiap kali mereka meluncurkannyaKafkaSaat menyajikan, perlu dilakukan terlebih dahuluPenjaga kebun binatangMulai, lalu mulaiKafka, langkah-langkahnya cukup rumit.
KafkaDiterbitkan sekarang2.8versi, memungkinkan pengguna untuk menggunakanPenjaga kebun binatangberjalan di bawahKafka, versi ini akan bergantung padaPenjaga kebun binatangPengontrol diubah menjadi berdasarkanRakit KafkadariKuorumPengontrol (mode kraft).

Mulai melalui ZooKeeper

Lihat file konfigurasi:

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: Ubah konfigurasi ZooKeeper

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

2: Mulai Penjaga Kebun Binatang
Masuk ke direktori bin kafka:

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

3: Mulai Kafka

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

Lihat log permulaan
Jika Anda tidak melihat proses Kafka menggunakan perintah JPS setelah menjalankan perintah startup, startup mungkin gagal.Anda dapat memeriksa log startup di bawah jalur yang sesuai dan mengganti jalur tersebut dengan jalur Kafka Anda sendiri.
/usr/local/kafka_2.13-3.7.1/bin/hs_err_pid***.log

Memulai Kafka dalam mode KRaft

Buka Kafka kamiKonfigurasidirektori, ada folder KRaft.
1: Ubah kami untuk mengubah lokasi penyimpanan data

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

2: Hasilkan ID unik untuk direktori penyimpanan
Ada file kafka-storage.sh di direktori bin kafka

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

3: Format direktori penyimpanan

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

Hasil dari:

4: Mulai Kafka

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