תחילת העבודה עם אפאצ'י קפקא
לפני התקנת Apache Kafka, עליך להתקין את Java וחשבון משתמש עם הרשאות sudo. יתר על כן, מומלץ להחזיק בזיכרון RAM של 2GB ומעלה להפעלה תקינה של קפקא.
השלבים הבאים ידריכו אותך כיצד להתקין את אפאצ'י קפקא.
התקנת Java
נדרשת Java כדי להתקין את Kafka. בדוק אם לאובנטו שלך מותקנת Java על ידי בדיקת הגרסה באמצעות הפקודה הבאה:
$ java --גִרְסָה
אם Java אינו מותקן, השתמש בפקודות הבאות כדי להתקין את Java OpenJDK.
$ סודו מַתְאִים להתקין ברירת מחדל-jdk
יצירת חשבון משתמש
כאשר Java כבר מותקן, צור חשבון משתמש שאינו שורש. אנחנו גם צריכים לתת לו כמה הרשאות sudo על ידי הוספת המשתמש לקבוצת sudo באמצעות הפקודה הבאה:
$ סודו adduser linuxhint
$ סודו adduser linuxhint סודו
היכנס לחשבון המשתמש החדש שנוצר.
מתקין את קפקא
אתה צריך להוריד את Apache Kafka העדכני ביותר מדף ההורדות הרשמי. הורד את הקבצים הבינאריים שלו באמצעות ה wget הפקודה כפי שמוצג בקטע הבא:
$ wget https: // downloads.apache.org / קפקא / 3.2.3 / kafka_2.12-3.2.3.tgz 
לאחר הורדת הקובץ הבינארי, חלץ אותו באמצעות ה- לוקח הפקודה והעבר את הספרייה שחולצה ל- /opt/kafka.
לאחר מכן, צור את סקריפטים מערכתיים בשביל ה שומר גן החיות וה קפקא שירותים המסייעים בהתחלה והפסקת השירותים.
השתמש בעורך לבחירה כדי ליצור את הסקריפטים המערכתיים ולהדביק את התכנים הבאים. התחל עם שומר גן החיות:
$ סודו ננו / וכו / systemd / מערכת / zookeeper.serviceהדבק את הדברים הבאים:
[ יחידה ]תיאור =שרת Apache Zookeeper
תיעוד =http: // zookeeper.apache.org
דורש =network.target מרחוק-fs.target
לאחר =network.target מרחוק-fs.target
[ שֵׁרוּת ]
סוּג =פשוט
ExecStart = / העדיף / קפקא / פַּח / zookeeper-server-start.sh / העדיף / קפקא / תצורה / שומר גן חיות.נכסים
ExecStop = / העדיף / קפקא / פַּח / zookeeper-server-stop.sh
אתחול =על לא נורמלי
[ להתקין ]
WantedBy =multi-user.target
שמור את הקובץ. צור את קובץ systemd עבור הקפקא והדבק את התוכן הבא:
בעת הדבקה, ודא שהגדרת את הנתיב הנכון עבור ה-Java שהתקנת במערכת שלך.
[ יחידה ]תיאור =שרת אפאצ'י קפקא
תיעוד =http: // kafka.apache.org / documentation.html
דורש =zookeeper.service
[ שֵׁרוּת ]
סוּג =פשוט
סביבה = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / העדיף / קפקא / פַּח / kafka-server-start.sh / העדיף / קפקא / תצורה / server.properties
ExecStop = / העדיף / קפקא / פַּח / kafka-server-stop.sh
אתחול =על לא נורמלי
[ להתקין ]
WantedBy =multi-user.target
לאחר שתסיים, החל את השינויים על ידי טעינה מחדש של הדמון systemd:
לאחר מכן, הפעל את שירות Zookeeper והפעל אותו באמצעות הפקודות הבאות:
$ סודו systemctl התחל zookeepe < חָזָק > ר חָזָק >
אתה גם צריך לעשות את אותו הדבר עבור קפקא:
$ סודו systemctl התחל קפקא
לאחר שתתחיל את השירותים, תוכל לאמת את הסטטוס שלהם לפני שניצור נושא בקפקא.
הדבר הטוב עם קפקא הוא שיש מספר סקריפטים שאתה יכול להשתמש בהם.
בואו ניצור נושא חדש בשם linuxhint1 משתמש ב kafka-topics.sh סקריפט עם מחיצה אחת ושכפול. השתמש בפקודה הבאה:
$ סודו -ב לינוקס / העדיף / קפקא / פַּח / kafka-topics.sh --לִיצוֹר --bootstrap-שרת מארח מקומי: 9092 -- גורם שכפול 1 --מחיצות 1 --נוֹשֵׂא linuxhint1 
שימו לב שהנושא שלנו נוצר. אנו יכולים לראות את ההודעה הקודמת כדי לוודא זאת.
לחלופין, תוכל לרשום את הנושאים הזמינים באמצעות -רשימה אפשרות בפקודה הבאה. זה אמור להחזיר את הנושא שיצרנו:S
$ סודו -ב לינוקס / העדיף / קפקא / פַּח / kafka-topics.sh --רשימה --bootstrap-שרת מארח מקומי: 9092 
עם יצירת נושא קפקא, אתה יכול להתחיל לכתוב את נתוני הזרמים על קפקא-קונסול-מפיק.ש ולבדוק אם זה משתקף אצלך consumer.sh.
פתחו את המעטפת שלכם וגשו לנושא שיצרנו באמצעות ה-producer.sh כפי שמוצג להלן:
$ סודו -ב לינוקס / העדיף / קפקא / פַּח / kafka-console-producer.sh --רשימת ברוקר מארח מקומי: 9092 --נוֹשֵׂא linuxhint1 
לאחר מכן, פתחו מעטפת נוספת וגשו לנושא קפקא באמצעות ה-consumer.sh.
כששתי הקונכיות פתוחות, אתה יכול לשלוח הודעה בקונסולת המפיק. כל מה שתקליד בא לידי ביטוי בקונסולת הצרכנים המאשרת שהאפאצ'י קפקא שלנו פועל.
סיכום
עם מדריך זה, כעת יש לך את כל השלבים שאתה יכול לבצע כדי להתקין את Apache Kafka באובונטו 22.04 שלך. בתקווה, הצלחת לעקוב אחר כל שלב ולהתקין את האפאצ'י קפקא שלך וליצור נושאים להפעלת ייצור פשוט לצרכן ומפיק. אתה יכול ליישם את אותו הדבר בייצור גדול.