Quomodo incipere Kafka post Zookeeper relicta?

2024-07-08

Quam ut download Kafaka

Website electronica inscriptio
Ultima versio Kafka est currently 3.7.1

Duos versiones infra notitia videre possumus? Quid istuc est?

Scala 2.12 - kafka_2.12-3.7.1.tgz (asc, sha512)
Scala 2.13 - kafka_2.13-3.7.1.tgz (asc, sha512)
Scire debemus instantiam Kafka integram continere saltem 3 partes:
Producentis
Broker
Producentis Consumer
Parturientes et consumptores lingua Java utuntur, et Sector utitur lingua Scala, sic intelleges. 2.12 et 2.13 versiones Scala actualiter sunt, 3.7.1 numerus versionis officialis realis Kafka est.

Kafka installation

Primum opus est ut ut ministrator noster in Java environment installed:

java -version

Download kafka:
Denota semita in qua condimus per -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

Unzip:

tar -zxvf  kafka_2.13-3.7.1.tgz

Kafka configuratione et startup

Apicibus
KafkaSummus throughput distributus est systema nuntiandi-subscribe nuntiandi quae omnia actionis fluunt notitiae consumerent processus in website.
KafkaIn prioribus versionibus, si nihilZooKeeper,Kafkanon munus.
usus estkafkadevelopers scire debetis, quod omne tempus deducuntkafkaQuando autem servit, primo necesse estZookeeperSatus, tunc satuskafkagradus admodum implicati sunt.
KafkaNunc editis2.8version, permittens utentesZooKeepercurrens subKafka, haec versio penderetZooKeeperModeratorem in unum secundumKafka Raftof*QuormController (KRaft modus).

Satus per ZooKeeper

Configuratione file videre:

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

I: Modify ZooKeeper configuratione

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

II: Committitur ZooKeeper
Intra kafka bin directorium:

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

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

Visum satus iniuriarum
Si non videris Kafka processum utendi mandatum JPS, postquam startup mandatum exsequens, startup defecisse potest.Satum initium sub calle respondente includere potes et iter cum tuo Kafka repone.
/usr/local/kafka_2.13-3.7.1/bin/hs_err_pid***.log

Satus Kafka in KRaft modus

Aperi nostram KafkaMandodirectorium, KRaft folder est.
I: Modificare nos ad mutare notitia repono locus

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

II: Generate a unique ID pro repono Directory
Est fasciculus kafka-storage.sh in indice bin kafka

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

III, Forma repono Directory

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

Eventus:

4: Incipit Kafka

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

Technology sharing