ካፋ ማዘጋጀት - 4 ደረጃዎች

2024 ደራሲ ደራሲ: John Day | [email protected]. ለመጨረሻ ጊዜ የተሻሻለው: 2024-01-30 07:31

መግቢያ ፦

Apache Kafka በስካላ ውስጥ በተፃፈው Apache ሶፍትዌር ፋውንዴሽን የተገነባ ክፍት ምንጭ ሊሰፋ የሚችል እና ከፍተኛ የውጤት መላላኪያ ስርዓት ነው። Apache Kafka አንድ ነጠላ ዘለላ ለትልቅ አከባቢ እንደ ማዕከላዊ የመረጃ ዳራ ሆኖ እንዲያገለግል በልዩ ሁኔታ የተነደፈ ነው። እንደ ActiveMQ እና RabbitMQ ካሉ ሌሎች የመልእክት ደላሎች ስርዓቶች ጋር ሲነፃፀር እጅግ የላቀ ውጤት አለው። በእውነተኛ-ጊዜ ውሂብ ብዙ ጥራዞችን በብቃት ለማስተናገድ ይችላል። ካፍካ በአንድ ነጠላ የ Apache አገልጋይ ላይ ወይም በተሰራጨ በተሰበሰበ አካባቢ ውስጥ ማሰማራት ይችላሉ።

ዋና መለያ ጸባያት:

የካፋ አጠቃላይ ባህሪዎች እንደሚከተለው ናቸው

የማያቋርጥ የጊዜ አፈፃፀም በሚሰጥ ዲስክ ላይ የማያቋርጥ መልእክት።

በመቶ ሺዎች የሚቆጠሩ መልዕክቶችን በሰከንድ ከሚደግፉ የዲስክ መዋቅሮች ጋር ከፍተኛ ውጤት።

ያለ ማሰራጨት በቀላሉ የሚሰራጨው የስርዓት ስርዓት።

ባለብዙ ተመዝጋቢዎችን ይደግፋል እና ውድቀት በሚከሰትበት ጊዜ ሸማቾችን በራስ-ሰር ሚዛናዊ ያደርጋል።

ይህ አጋዥ ስልጠና በኡቡንቱ 16.04 አገልጋይ ላይ Apache Kafka ን እንዴት እንደሚጭኑ እና እንደሚያዋቅሩ ያሳያል።

መስፈርቶች

የኡቡንቱ 16.04 አገልጋይ።

በአገልጋይዎ ላይ ከተዋቀረ እጅግ የላቀ የተጠቃሚ መብት ጋር ሥር ያልሆነ የተጠቃሚ መለያ።

ደረጃ 1: ጃቫን መጀመር እና መጫን

1) የኡቡንቱ 16.04 አገልጋይዎ ሙሉ በሙሉ ወቅታዊ መሆኑን ማረጋገጥ እንጀምር።

የሚከተሉትን ትዕዛዞች በማሄድ አገልጋይዎን ማዘመን ይችላሉ--

sudo apt -get update -y

sudo apt -get upgrade -y

2) ጃቫን መጫን

በሚከተለው ትዕዛዝ ማሽንዎ ቀድሞውኑ የተጫነ ወይም የጃቫ ነባሪ ሥሪት ካለው ያረጋግጡ--

java -version

ምንም እንኳን ጃቫ ግን ዝቅተኛ ስሪት ቢኖሩትም እሱን ማሻሻል ይኖርብዎታል።

ጃቫን በ:- መጫን ይችላሉ-

sudo apt-get install default-jdk

ወይም

የ Webupd8 ቡድን PPA ማከማቻን በመጠቀም Oracle JDK 8 ን መጫን ይችላሉ።

ማከማቻውን ለማከል የሚከተለውን ትዕዛዝ ያሂዱ--

sudo add-apt-repository -y ppa: webupd8team/java

sudo apt-get install oracle-java8-installer -y

ደረጃ 2: Zookeeper ን ይጫኑ

Zookeeper ምንድን ነው?

Zookeeper የውቅረት መረጃን ለመጠበቅ ፣ ለመሰየም ፣ የተሰራጨ ማመሳሰልን ለማቅረብ እና የቡድን አገልግሎቶችን ለማቅረብ ማዕከላዊ አገልግሎት ነው። እነዚህ ሁሉ ዓይነት አገልግሎቶች በተወሰኑ መተግበሪያዎች ወይም በሌላ መልኩ ጥቅም ላይ ይውላሉ። በተተገበሩ ቁጥር አይቀሬ የሆኑትን ሳንካዎች እና የዘር ሁኔታዎችን ለማስተካከል ብዙ ሥራ አለ። እንደነዚህ ዓይነቶቹን አገልግሎቶች ለመተግበር አስቸጋሪ ስለሆነ ፣ አፕሊኬሽኖች ብዙውን ጊዜ በእነሱ ላይ ይንሸራተታሉ ፣ ይህም በለውጥ ፊት እንዲሰባበሩ እና ለማስተዳደር አስቸጋሪ ያደርጋቸዋል። በትክክል በተሠራበት ጊዜ እንኳን ፣ የእነዚህ አገልግሎቶች የተለያዩ ትግበራዎች ትግበራዎቹ በሚተላለፉበት ጊዜ ወደ የአስተዳደር ውስብስብነት ይመራሉ።

Apache Kafka ን ከመጫንዎ በፊት የእንስሳት ጠባቂ የሚገኝ እና የሚሰራ መሆን ያስፈልግዎታል። ZooKeeper የውቅረት መረጃን ለመጠበቅ ፣ የተከፋፈለ ማመሳሰልን ፣ ስም መስጠት እና የቡድን አገልግሎቶችን ለማቅረብ ክፍት ምንጭ አገልግሎት ነው።

1) በነባሪ የ Zookeeper ጥቅል በኡቡንቱ ነባሪ ማከማቻ ውስጥ ይገኛል

የሚከተለውን ትዕዛዝ በማሄድ ሊጭኑት ይችላሉ--

sudo apt-get install zookeeperd

መጫኑ ከተጠናቀቀ በኋላ እንደ ዴሞን በራስ -ሰር ይጀምራል። በነባሪ Zookeeper ወደብ 2181 ላይ ይሠራል።

የሚከተለውን ትዕዛዝ በማሄድ ሊፈትኑት ይችላሉ

netstat -ant | grep: 2181

መውጫው 2181 ወደብ እየተደመጠ መሆኑን ሊያሳይዎት ይገባል።

ደረጃ 3 - የካፋ አገልጋይ ይጫኑ እና ያስጀምሩ

አሁን ጃቫ እና ዙኪፔር ተጭነዋል ፣ ካፋካ ከ Apache ድር ጣቢያ ለማውረድ እና ለማውጣት ጊዜው አሁን ነው።

1) ካፍካ ለማውረድ ኩርባ ወይም wget ን መጠቀም ይችላሉ ((የካፍካ ስሪት 0.10.1.1)

የካፍካ ቅንብርን ለማውረድ የሚከተለውን ትእዛዝ ያሂዱ--

curl -O

ወይም

wget

2) ለካፍካ ማውጫ ይፍጠሩ

በመቀጠል ለካፍካ መጫኛ ማውጫ ይፍጠሩ

sudo mkdir /opt /kafka

ሲዲ /መርጦ /ካፍካ

3) የወረደውን አቃፊ ይንቀሉ

sudo tar -zxvf /home/user_name/Downloads/kafka_2.11-0.10.1.1.tgz -C/opt/kafka/

*በተጠቃሚ ስምዎ መሠረት የተጠቃሚ ስም ይለውጡ

4) የካፍካ አገልጋዩን ያስጀምሩ

ቀጣዩ ደረጃ የካፍካ አገልጋይ መጀመር ነው ፣ የሚከተለውን ትዕዛዝ በመጠቀም /opt/kafka/kafka_2.11-0.10.1.1/bin/ ማውጫ ላይ የሚገኘውን kafka-server-start.sh ስክሪፕት በማሄድ መጀመር ይችላሉ--

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) የካፍካ አገልጋይ በደንብ እየሰራ መሆኑን ያረጋግጡ

አሁን ወደብ 9092 ላይ የሚያሄድ እና የሚያዳምጥ የካፍካ አገልጋይ አለዎት።

አሁን ፣ የማዳመጥ ወደቦችን መፈተሽ እንችላለን-

- መካነ አራዊት - 2181

- ካፍካ - 9092

netstat -ant | grep -E ': 2181 |: 9092'

ደረጃ 4 የካፍካ አገልጋይዎን ይፈትሹ

አሁን የካፋ አገልጋዩ በትክክል እየሰራ መሆኑን ለማረጋገጥ ጊዜው አሁን ነው።

1) አዲስ ርዕስ ይፍጠሩ

ካፍካን ለመሞከር የሚከተለውን ትዕዛዝ በመጠቀም በአፓቼ ካፍካ ውስጥ “ሙከራ” የሚል የናሙና ርዕስ ይፍጠሩ

/opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-topics.sh-ፍጠር-የርዕስ ምርመራ-ተንከባካቢ አካባቢያዊ መንፈስ 2181-ክፍል 1-ማባዛት-ምክንያት 1

2) ርዕስዎ በተሳካ ሁኔታ ከተፈጠረ ያረጋግጡ

አሁን የሚከተለውን ትእዛዝ በማሄድ በአፓቼ ካፍካ ላይ ያሉትን አርእስቶች እንዲዘረዝር ዙፐር ይጠይቁ -

/opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-topics.sh-ዝርዝር-ጠባቂ ጠባቂ አካባቢያዊ: 2181

3) እርስዎ የፈጠሩትን ርዕስ በመጠቀም መልእክት ያትሙ

አስተጋባ "ሰላም ዓለም" | /opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-console-producer.sh-Broker-list localhost: 9092-የገጽ ሙከራ

4) በተፈጠረው ርዕስ ላይ መልዕክቱን ይቀበሉ

/opt/kafka/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh --bootstrap-server localhost: 9092-የገፅ ሙከራ -ከጅምር

5) በአንድ ርዕስ ላይ ካፍካ በመጠቀም ፋይል ለመላክ

kafka-console-producer.sh-Broker-list localhost: 9092 –topic ሙከራ