Apache Kafka'ya Başlarken
Apache Kafka'yı kurmadan önce, Java'nın kurulu olması ve sudo ayrıcalıklarına sahip bir kullanıcı hesabına sahip olmanız gerekir. Ayrıca, Kafka'nın düzgün çalışması için RAM'in 2GB ve üzeri olması önerilir.
Aşağıdaki adımlar, Apache Kafka'nın nasıl kurulacağı konusunda size rehberlik edecektir.
Java'yı yükleme
Java, Kafka'yı yüklemek için gereklidir. Aşağıdaki komutu kullanarak sürümü kontrol ederek Ubuntu'nuzda yüklü bir Java olup olmadığını kontrol edin:
$ java --versiyon
Java kurulu değilse, Java OpenJDK'yı kurmak için aşağıdaki komutları kullanın.
$ sudo uygun Yüklemek varsayılan-jdk
Kullanıcı Hesabı Oluşturma
Java zaten kuruluyken, root olmayan bir kullanıcı hesabı oluşturun. Ayrıca, aşağıdaki komutu kullanarak kullanıcıyı sudo grubuna ekleyerek ona bazı sudo ayrıcalıkları vermemiz gerekiyor:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Yeni oluşturulan kullanıcı hesabına giriş yapın.
Kafka'yı Yükleme
Resmi indirme sayfasından en son Apache Kafka'yı indirmeniz gerekir. kullanarak ikili dosyalarını indirin. wget aşağıdaki şekilde gösterildiği gibi komut:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
İkili dosya indirildikten sonra, dosyayı kullanarak çıkarın. alır komutunu verin ve çıkarılan dizini şuraya taşıyın. /opt/kafka.
Ardından, oluştur sistem komut dosyaları için hayvan bakıcısı ve Kafkas Hizmetlerin başlatılmasına ve durdurulmasına yardımcı olan hizmetler.
Systemd komut dosyalarını oluşturmak için istediğiniz bir düzenleyiciyi kullanın ve aşağıdaki içerikleri yapıştırın. Zookeeper ile başlayın:
$ sudo nano / vb / sistem / sistem / hayvan bakıcısı.servisAşağıdakileri yapıştırın:
[ Birim ]Tanım =Apache Zookeeper sunucusu
belgeler =http: // zookeeper.apache.org
Gereklilikler =network.target uzak-fs.target
Sonrasında =network.target uzak-fs.target
[ Hizmet ]
Tip =basit
ExecStart = / tercih / kafka / çöp Kutusu / zookeeper-server-start.sh / tercih / kafka / yapılandırma / zookeeper.properties
ExecStop = / tercih / kafka / çöp Kutusu / zookeeper-server-stop.sh
Tekrar başlat = anormal
[ Düzenlemek ]
AranıyorTarafından =çok kullanıcılı.hedef
Dosya 'yı kaydet. Kafka için systemd dosyasını oluşturun ve aşağıdaki içeriği yapıştırın:
Yapıştırırken, sisteminize kurduğunuz Java için doğru yolu ayarladığınızdan emin olun.
[ Birim ]Tanım =Apache Kafka Sunucusu
belgeler =http: // kafka.apache.org / belgeler.html
Gereklilikler =hayvan bekçisi.servis
[ Hizmet ]
Tip =basit
Çevre = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / tercih / kafka / çöp Kutusu / kafka-server-start.sh / tercih / kafka / yapılandırma / server.properties
ExecStop = / tercih / kafka / çöp Kutusu / kafka-server-stop.sh
Tekrar başlat = anormal
[ Düzenlemek ]
AranıyorTarafından =çok kullanıcılı.hedef
Tamamlandığında, systemd arka plan programını yeniden yükleyerek değişiklikleri uygulayın:
Ardından, Zookeeper hizmetini etkinleştirin ve aşağıdaki komutları kullanarak başlatın:
$ sudo systemctl zookeepe'i başlat < kuvvetli > r kuvvetli >
Aynı şeyi Kafka için de yapmanız gerekir:
$ sudo systemctl kafka'yı başlat
Hizmetleri başlattığınızda, Kafka'da bir konu oluşturmadan önce durumlarını doğrulayabilirsiniz.
Kafka'nın iyi yanı, kullanabileceğiniz birden fazla komut dosyası olmasıdır.
adında yeni bir konu oluşturalım linuxhint1 kullanmak kafka-topics.sh bir bölüm ve bir çoğaltma ile komut dosyası. Aşağıdaki komutu kullanın:
$ sudo -içinde linux ipucu / tercih / kafka / çöp Kutusu / kafka-topics.sh --oluşturmak --bootstrap-sunucusu yerel ana bilgisayar: 9092 --replication-faktörü 1 --bölümler 1 --başlık linuxhint1 
Konumuzun oluşturulduğunu unutmayın. Bunu doğrulamak için önceki mesajı görebiliriz.
Alternatif olarak, mevcut konuları aşağıdakileri kullanarak listeleyebilirsiniz: -liste Aşağıdaki komutta seçenek. Oluşturduğumuz konuyu döndürmeli:S
$ sudo -içinde linux ipucu / tercih / kafka / çöp Kutusu / kafka-topics.sh --liste --bootstrap-sunucusu yerel ana bilgisayar: 9092 
Kafka konusu oluşturularak, akış verilerini sayfaya yazmaya başlayabilirsiniz. Kafka-konsol-prodüktör.sh ve size yansıyıp yansımadığını kontrol edin. tüketici.sh.
Kabuğunuzu açın ve aşağıda gösterildiği gibi Producer.sh kullanarak oluşturduğumuz konuya erişin:
$ sudo -içinde linux ipucu / tercih / kafka / çöp Kutusu / kafka-konsol-prodüktör.sh -- komisyoncu listesi yerel ana bilgisayar: 9092 --başlık linuxhint1 
Ardından, başka bir kabuk açın ve tüketici.sh kullanarak Kafka konusuna erişin.
Açılan iki mermi ile üretici konsolunda mesajlaşabilirsiniz. Ne yazarsanız yazın, Apache Kafka'mızın çalışır durumda olduğunu onaylayan tüketici konsoluna yansıtılır.
Çözüm
Bu kılavuzla, artık Ubuntu 22.04'ünüze Apache Kafka'yı kurmak için izleyebileceğiniz tüm adımlara sahipsiniz. Umarım, her adımı takip etmeyi ve Apache Kafka'nızı kurmayı ve basit bir tüketici ve üretici üretimi yürütmek için konular oluşturmayı başardınız. Aynı şeyi büyük üretimde de uygulayabilirsiniz.