Kuinka aloittaa Kafka Zookeeperin hylkäämisen jälkeen?

2024-07-08

Kuinka ladata Kafaka

Virallisen verkkosivuston osoite
Kafkan uusin versio on tällä hetkellä 3.7.1

Voimmeko nähdä alla olevat kahden version tiedot? Mitä tuo tarkoittaa?

Scala 2.12 – kafka_2.12-3.7.1.tgz (asc, sha512)
Scala 2.13 – kafka_2.13-3.7.1.tgz (asc, sha512)
Meidän pitäisi tietää, että täydellinen Kafka-esiintymä sisältää vähintään 3 osaa:
Tuottaja
Välittäjä
Tuottaja-Kuluttaja
Tuottajat ja kuluttajat käyttävät Java-kieltä, ja välittäjä käyttää Scala-kieltä, joten ymmärrät. 2.12 ja 2.13 ovat itse asiassa Scalan versioita, ja 3.7.1 on Kafkan todellinen virallinen versionumero.

Kafka asennus

Meidän on ensin varmistettava, että palvelimellemme on asennettu Java-ympäristö:

java -version

Lataa kafka:
Määritä polku, johon se tallennetaan, -o:lla

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

Pura:

tar -zxvf  kafka_2.13-3.7.1.tgz

Kafkan konfigurointi ja käynnistys

Vinkkejä
KafkaSe on korkean suorituskyvyn hajautettu julkaisu-tilaa -viestijärjestelmä, joka pystyy käsittelemään kaikkia verkkosivustolla olevien kuluttajien toimintakulkutietoja.
KafkaAiemmissa versioissa, jos ei ollutZooKeeper,Kafkaei toimi.
käytettykafkakehittäjien tulisi tietää tämä joka kerta, kun he käynnistävätkafkaTarjottaessa on välttämätöntä ensinEläintarhanhoitajaAloita ja sitten aloitakafka, vaiheet ovat melko monimutkaisia.
KafkaJulkaistu nyt2.8versio, jonka avulla käyttäjät voivat käyttääZooKeeperjuoksemassa alleKafka, tämä versio riippuuZooKeeperOhjain muutettiin sellaiseksi, joka perustuuKafkan lautta/QuormOhjain (KRraft-tila).

Aloita ZooKeeperin kautta

Katso asetustiedosto:

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: Muokkaa ZooKeeper-asetuksia

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

2: Käynnistä ZooKeeper
Syötä kafkan roskapostihakemisto:

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

3: Aloita 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

Näytä käynnistysloki
Jos et näe JPS-komentoa käyttävää Kafka-prosessia käynnistyskomennon suorittamisen jälkeen, käynnistys on saattanut epäonnistua.Voit tarkistaa käynnistyslokin vastaavan polun alta ja korvata polun omalla Kafka-polullasi.
/usr/local/kafka_2.13-3.7.1/bin/hs_err_pid***.log

Kafkan käynnistäminen KRraft-tilassa

Avaa KafkammeKonfighakemistossa on KRraft-kansio.
1: Muokkaa meitä muuttaaksesi tietojen tallennuspaikkaa

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

2: Luo tallennushakemistolle yksilöllinen tunnus
Kafkan bin-hakemistossa on kafka-storage.sh-tiedosto

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

3: Alusta tallennushakemisto

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

Tulokset:

4: Aloita Kafka

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

Teknologian jakaminen