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