प्रौद्योगिकी साझेदारी

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

Kafaka कथं डाउनलोड् करणीयम्

आधिकारिक वेबसाइट पता
काफ्का इत्यस्य नवीनतमं संस्करणं सम्प्रति ३.७.१ अस्ति

अधः द्वयोः संस्करणयोः सूचनां द्रष्टुं शक्नुमः वा? तस्य किम् अर्थः ?

• स्काला २.१२ - कफ्का_२.१२-३.७.१.त्ग्ज (asc, sha512)
• स्काला २.१३ - कफ्का_२.१३-३.७.१.त्ग्ज (asc, sha512)
  अस्माभिः ज्ञातव्यं यत् सम्पूर्णे काफ्का-दृष्टान्ते न्यूनातिन्यूनं ३ भागाः सन्ति:
• निर्माता
• दलाल
• उत्पादक-उपभोक्ता
  उत्पादकाः उपभोक्ताश्च जावा भाषां उपयुञ्जते, दलालः च Scala भाषां उपयुङ्क्ते, अतः भवान् अवगमिष्यति । २.१२ तथा २.१३ वस्तुतः स्काला इत्यस्य संस्करणाः सन्ति, ३.७.१ च काफ्का इत्यस्य वास्तविकः आधिकारिकः संस्करणसङ्ख्या अस्ति ।

काफ्का स्थापना

अस्माभिः प्रथमं सुनिश्चितं कर्तव्यं यत् अस्माकं सर्वरे जावा वातावरणं संस्थापितम् अस्ति:

java -version

काफ्का डाउनलोड करें:
यत्र वयं तत् -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

काफ्का विन्यासः प्रारम्भः च

संकेता
काफ्काइदं उच्च-थ्रूपुट् वितरितं प्रकाश-सदस्यता-सन्देश-प्रणाली अस्ति या वेबसाइट् मध्ये उपभोक्तृणां सर्वाणि क्रिया-प्रवाह-दत्तांशं संसाधितुं शक्नोति ।
काफ्कापूर्वसंस्करणेषु यदि नासीत्चिडियाघरपालकः,काफ्कान कार्यं करिष्यति।
प्रयुक्तकफ्काविकासकाः ज्ञातव्यं यत् प्रत्येकं प्रक्षेपणं कुर्वन्तिकफ्कासेवायां प्रथमं करणीयम्चिडियाघरपालकःआरभत, ततः आरभतकफ्का, सोपानानि तु अत्यन्तं जटिलानि सन्ति।
काफ्काअधुना प्रकाशितम्2.8संस्करणं, उपयोक्तृभ्यः उपयोक्तुं अनुमतिं ददातिचिडियाघरपालकःrun underकाफ्का, एतत् संस्करणं निर्भरं भविष्यतिचिडियाघरपालकःनियन्त्रकः आधारितः एकस्मिन् परिणतः अभवत्काफ्का राफ्टइत्यस्य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 आरभ्यताम्
kafka इत्यस्य bin निर्देशिकां प्रविशन्तु:

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

३: काफ्का आरभत

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

स्टार्टअप लॉग् पश्यन्तु
यदि भवान् startup आदेशं निष्पादयित्वा JPS आदेशस्य उपयोगेन Kafka प्रक्रियां न पश्यति तर्हि startup विफलं जातम् ।भवान् तत्सम्बद्धमार्गस्य अधः स्टार्टअप-लॉग् परीक्षितुं शक्नोति तथा च मार्गस्य स्थाने स्वस्य काफ्का-मार्गं प्रतिस्थापयितुं शक्नोति ।
/usr/local/kafka_2.13-3.7.1/bin/hs_err_pid***.log

KRaft मोड् मध्ये काफ्का आरभ्यते

अस्माकं काफ्का उद्घाटयतुConfigनिर्देशिका, तत्र KRaft पुटम् अस्ति ।
1: अस्मान् परिवर्तनं कृत्वा दत्तांशसञ्चयस्थानं परिवर्तयन्तु

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

2: भण्डारणनिर्देशिकायाः ​​कृते एकं अद्वितीयं ID जनयन्तु
kafka इत्यस्य bin निर्देशिकायां kafka-storage.sh सञ्चिका अस्ति

./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

अस्य परिणामाः : १.

४: काफ्का आरभत

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