Orodha ya maudhui:
- Hatua ya 1: Kuanza na Kusanikisha Java
- Hatua ya 2: Sakinisha Zookeeper
- Hatua ya 3: Sakinisha na Anza Seva ya Kafka
- Hatua ya 4: Jaribu seva yako ya Kafka
Video: Kuanzisha Kafka: Hatua 4
2024 Mwandishi: John Day | [email protected]. Mwisho uliobadilishwa: 2024-01-30 12:51
Utangulizi:
Apache Kafka ni mfumo wa ujumbe wa wazi unaoweza kutisha na wa hali ya juu uliotengenezwa na Apache Software Foundation iliyoandikwa huko Scala. Apache Kafka imeundwa mahsusi kuruhusu nguzo moja kutumika kama mhimili mkuu wa data kwa mazingira makubwa. Ina upitishaji wa juu zaidi ikilinganishwa na mifumo mingine ya mawakala wa ujumbe kama ActiveMQ na RabbitMQ. Ni uwezo wa kushughulikia idadi kubwa ya data ya wakati halisi kwa ufanisi. Unaweza kupeleka Kafka kwenye seva moja ya Apache au katika mazingira yaliyosambazwa.
vipengele:
Makala ya jumla ya Kafka ni kama ifuatavyo.
Endelea kutuma ujumbe kwenye diski ambayo hutoa utendaji wa wakati wote.
Upitishaji wa juu na miundo ya diski inayounga mkono mamia ya maelfu ya ujumbe kwa sekunde.
Kusambazwa kwa mizani ya mfumo kwa urahisi bila wakati wa kupumzika.
Inasaidia wanachama wengi na husawazisha moja kwa moja watumiaji wakati wa kutofaulu.
Mafunzo haya yanaonyesha jinsi ya kusanidi na kusanidi Apache Kafka kwenye seva ya Ubuntu 16.04.
Mahitaji
Seva ya Ubuntu 16.04.
Akaunti ya mtumiaji isiyo ya mizizi na upendeleo mkubwa wa mtumiaji uliowekwa kwenye seva yako.
Hatua ya 1: Kuanza na Kusanikisha Java
1) Wacha tuanze kuhakikisha kuwa seva yako ya Ubuntu 16.04 imesasishwa kabisa
Unaweza kusasisha seva yako kwa kutumia amri zifuatazo: -
Sudo apt-pata sasisho -y
Sudo apt-kupata sasisho -y
2) Kufunga Java
Angalia ikiwa mashine yako ina java ambayo tayari imewekwa au ina toleo chaguomsingi la java kwa amri ifuatayo: -
mabadiliko ya java
Hata kama una java lakini toleo la chini, italazimika kuiboresha.
Unaweza kufunga Java na: -
Sudo apt-get kufunga default-jdk
AU
Unaweza kusanikisha Oracle JDK 8 ukitumia ghala la timu ya Webupd8 PPA.
Ili kuongeza hazina, tumia amri ifuatayo: -
sudo kuongeza-apt-repository -y ppa: webupd8team / java
Sudo apt-get install oracle-java8-kisakinishi -y
Hatua ya 2: Sakinisha Zookeeper
Zookeeper ni nini?
Zookeeper ni huduma kuu ya kudumisha habari ya usanidi, kutaja jina, kutoa usawazishaji uliosambazwa, na kutoa huduma za kikundi. Aina hizi zote za huduma hutumiwa kwa namna fulani au nyingine na programu zinazosambazwa. Kila wakati zinatekelezwa kuna kazi nyingi ambazo zinaenda kurekebisha mende na hali ya mbio ambazo haziepukiki. Kwa sababu ya ugumu wa kutekeleza huduma za aina hii, mwanzoni programu huzipunguza, ambazo huwafanya wawe brittle mbele ya mabadiliko na kuwa ngumu kudhibiti. Hata ikifanywa kwa usahihi, utekelezaji tofauti wa huduma hizi husababisha ugumu wa usimamizi wakati programu zinatumwa.
Kabla ya kusanikisha Apache Kafka, utahitaji kuwa na mtunza zoo anayepatikana na anayeendesha. ZooKeeper ni huduma ya chanzo wazi kwa kudumisha habari ya usanidi, kutoa usawazishaji uliosambazwa, kutaja jina na kutoa huduma za kikundi.
1) Kwa chaguo-msingi kifurushi cha Zookeeper kinapatikana katika hazina chaguomsingi ya Ubuntu
Unaweza kuiweka kwa kutumia amri ifuatayo: -
Sudo apt-get kufunga zookeeperd
Mara baada ya usakinishaji kumaliza, itaanza kama daemon moja kwa moja. Kwa chaguo-msingi Zookeeper itaendesha kwenye bandari 2181.
Unaweza kuijaribu kwa kutumia amri ifuatayo:
netstat -ant | grep: 2181
Kuweka nje kunapaswa kukuonyesha kuwa bandari 2181 inasikilizwa.
Hatua ya 3: Sakinisha na Anza Seva ya Kafka
Sasa kwa kuwa Java na ZooKeeper zimewekwa, ni wakati wa kupakua na kutoa Kafka kutoka kwa wavuti ya Apache.
1) Unaweza kutumia curl au wget kupakua Kafka: (Kafka toleo 0.10.1.1)
Tumia amri ifuatayo kupakua usanidi wa kafka: -
curl -O
AU
wget
2) Unda saraka ya Kafka
Ifuatayo, tengeneza saraka ya usanikishaji wa Kafka:
sudo mkdir / opt / kafka
cd / opt / kafka
3) Unzip folda iliyopakuliwa
sudo tar -zxvf / nyumba / user_name/Downloads/kafka_2.11-0.10.1.1.tgz -C / opt / kafka /
* Badilisha jina la mtumiaji kulingana na jina lako la mtumiaji
4) Anza seva ya kafka
Hatua inayofuata ni kuanza seva ya Kafka, unaweza kuianzisha kwa kutumia hati ya kafka-server-start.sh iliyoko /opt/kafka/kafka_2.11-0.10.1.1/bin/ saraka kwa kutumia amri ifuatayo: -
sudo /opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-server-start.sh /opt/kafka/kafka_2.11-0.10.1.1/config/server.properties
5) Angalia ikiwa Seva ya Kafka inafanya kazi vizuri
Sasa una seva ya Kafka inayoendesha na kusikiliza kwenye bandari 9092.
Sasa, tunaweza kuangalia bandari za kusikiliza:
- Mtunza Zoo: 2181
- Kafka: 9092
netstat -ant | grep -E ': 2181 |: 9092'
Hatua ya 4: Jaribu seva yako ya Kafka
Sasa, ni wakati wa kudhibitisha seva ya Kafka inafanya kazi kwa usahihi.
1) Unda mada mpya
Ili kujaribu Kafka, tengeneza mada ya mfano na jina "upimaji" katika Apache Kafka ukitumia amri ifuatayo:
/opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --create - mada ya upimaji - mwandishi wa habari mwenyeji: 2181 - sehemu 1 - kipengele cha kurudia 1
2) Angalia ikiwa mada yako iliundwa kwa mafanikio
Sasa, muulize Zookeeper kuorodhesha mada zinazopatikana kwenye Apache Kafka kwa kutumia amri ifuatayo:
/opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-topics.sh - orodha - mwenyeji wa habari mwenyeji: 2181
3) Chapisha ujumbe ukitumia mada uliyounda
mwangwi "ulimwengu wa hello" | /opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-console-producer.sh - orodha ya wafanyabiashara-wenyeji: 9092 - upimaji wa mada
4) Pokea ujumbe kwenye mada iliyoundwa
/opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh --bootstrap-server localhost: 9092 - upimaji wa mada -kuanzia mwanzo
5) Kutuma faili ukitumia kafka juu ya mada
kafka-console-producer.sh - orodha ya brokerhosthost: 9092 -kupima mada
Ilipendekeza:
Misingi ya VBScript - Kuanzisha Hati zako, Ucheleweshaji na Zaidi !: Hatua 5
Misingi ya VBScript - Kuanzisha Maandiko Yako, Kuchelewesha na Zaidi !: Karibu kwenye mafunzo yangu ya kwanza juu ya jinsi ya kutengeneza VBScript na notepad. Na faili za.vbs, unaweza kuunda pranks za kuchekesha au virusi hatari. Katika mafunzo haya, nitakuonyesha amri za msingi kama kuanza hati yako, kufungua faili na mengi zaidi. Katika t
Kuanzisha OS ya MotionEye kwenye Raspberry Pi Zero W: Hatua 5
Kuanzisha OS ya MotionEye kwenye Raspberry Pi Zero W: Baada ya kujaribu bodi ya ESP32-CAM kwenye video zilizopita, ni salama kusema kwamba ubora wa video sio mzuri sana. Ni bodi thabiti na yenye gharama kubwa sana ambayo pia ni rahisi kutumia na hii inafanya kuwa kamili kwa Kompyuta. Lakini
Lemaza Beep ya Kuanzisha PS4: Hatua 6
Lemaza Beep ya Kuanzisha PS4: 11pm. Kulala kwa familia, unaanzisha PS4 katika chumba cha kimya kabisa. NYUKI hufanya. Fikiria kinachotokea. Wacha tuachane na hii
Kuanzisha Blynk: Hatua 5
Kuanzisha Blynk: Katika mafunzo haya, utajifunza jinsi ya kuanzisha bodi yako ya Arduino na Blynk na kuifanya ili unapobonyeza kitufe huko Blynk taa ya LED (mimi binafsi ninashauri hii kwani esp32 ina Wifi na Bluetooth imejengwa- katika, ambayo inafanya kuwa nzuri kwa mimi
Kuanzisha Uunganisho wa WiFi na ESP8266 na Pata Anwani ya IP ya Mitaa: Hatua 3
Kuanzisha Uunganisho wa WiFi na ESP8266 na Pata Anwani ya IP ya Mitaa: Katika mafunzo haya tutaona jinsi ya kuanzisha unganisho la WiFi na bodi ya WiFi ya ESP8266. Tutaunganisha hiyo na mtandao wa WiFi wa ndani