Apache Kafka, güçlü bir mesaj komisyoncusu hizmetidir. Çok hızlı ve güvenilirdir. Apache Kafka açık kaynaklıdır ve kullanımı ücretsizdir. Java ile yazılmıştır. Bu yazıda size Apache Kafka’da bölümlerin nasıl kurulacağını göstereceğim. Hadi başlayalım.
Apache Kafka’nın temellerini anlamak yeminlers, Kafka’yı bilmek zorundasın Başlık ilk.
a Başlık Apache Kafka için MariaDB gibi bir SQL veritabanındaki bir veritabanı gibi. a Başlık Apache Kafka’da mesajları gruplandırmak için kullandığınız bir adı veya tanımlayıcısı vardır.
a yeminler her biri bir kanala benziyor Başlık. a Başlık çok olabilir yeminlers veya kanallar.
İki bilgisayarı birbirine bağlayan bir ağ kablosunun biri veri gönderen, diğeri veri alan iki ucu vardır. Aynen bunun gibi, Apache Kafka iş parçacığının iki ucu vardır, Üreticiiletişim tüketicis. a Üretici Aşağıdakilerden herhangi birine mesaj oluşturur ve gönderir. yeminlerdivan Başlık. a tüketici Öte yandan gelen mesajları okur yeminlerdivan Başlık.
çoklu yeminlerFazlalığı artırmak için kanallar veya kanallar oluşturulur. Mesajları belirli bir şekilde gruplamak için de kullanılır. Başlık.
Bu, Apache Kafka’nın temelleri yeminlers. Apache Kafka bölümleri hakkında daha fazla bilgiyi başka bir özel makalede bulabilirsiniz. Apache Kafka bölünmüş NS
Apache Kafka’yı kurun:
Bunun nasıl yapılacağı hakkında ayrıntılı bir makalem var. Apache Kafka’yı Ubuntu’ya kuruniçinde okuyabilirsiniz
Küçük bir ayar ile Apache Kafka’yı diğer Linux dağıtımlarına da kurabilirsiniz.
Apache Kafka sunucusunu başlatma:
Apache Kafka kurulumu için yazımı takip ettiyseniz, öncelikle aşağıdaki komut ile Apache Kafka sunucusunu başlatın:
$ sudo kafka-server-start.sh /vb/kafka
Apache Kafka sunucusu başlamalıdır. Apache Kafka sunucusunu çalıştırmak istediğiniz sürece bu terminali açık bırakın.
Bir Apache Kafka teması oluşturun:
Apache Kafka oluşturabilirsiniz BaşlıkTestler Aşağıdaki komutla:
$ sudo kafka-topics.sh
Hadi yapalım veya yaratalım \
Hayvan koruma yerel ana bilgisayar:2181 \
transkripsiyon faktörü1 \
– bölümler1 \
–Takma ad Testler
NS BaşlıkTestler Oluşturulmalıdır. bu Başlık 1 bölme.
Oluşturmak istiyorsanız, diyelim n bölümler, ardından ayarlayın bölümler ile birlikte n.
Başka bir tane oluşturalım Başlıkdiyelimki kullanıcılarile birlikte 3yeminlers , ardından aşağıdaki komutu çalıştırın:
$ sudo kafka-topics.sh
Hadi yapalım veya yaratalım \
Hayvan koruma yerel ana bilgisayar:2181 \
transkripsiyon faktörü1 \
– bölümler3 \
–Takma adkullanıcılar
itaatkar kullanıcılar 3 ile oluşturulmalıdır yeminlers.
Konuya bölümlenmiş mesajlar ekleme:
a yeminlerEd A Harfi Başlık O anahtar ve bir değer. NS anahtar e değer genellikle b ile ayrılır virgül veya diğer özel karakter. Ayırmak için hangi özel karakteri kullandığınız önemli değil. anahtar e değer Erkek eş. Ama bu konuda her yerde aynı özel karakteri kullanmanız gerekiyor. Başlık. Aksi takdirde işler ters gidebilir.
NS anahtar herhangi birini belirtmek için kullanılır yeminler İleti Başlık ait olmak. Benzersiz olmalıdır. Başlık. Varsa 3yeminlers, o zaman kullanmalısın 3 Farklı anahtars. Böylece mesajlar bölünebilir 3yeminlers.
bizde var diyelim kullanıcılarBaşlık onun 3 kullanıcılar Anahtar 1Ve 2Beşinci 3her biri aşağıdakilerden herhangi birine ait 3yeminlers’nin Konu kullanıcıları.
İlk kullanıcıyı eklemek için aşağıdaki komutu çalıştırın. Anahtar 1 kullanmak Kafka API ürünü:
$ Eko“1, {isim: ‘Shahriar Shovon’, ülke: ‘BD’}”|sudo kafka-konsol-producer.sh
– Broker listesi yerel ana bilgisayar:9092 \
–Takma adkullanıcılar \
–Emlak ayrıştır.anahtar =NS \
–Emlak anahtar.ayırıcı =,
Artık mesajı listeden listeleyebilirsiniz. kullanıcılarBaşlık kullanmak Kafka Tüketici API’sı Aşağıdaki komutla:
$ sudo kafka-console-consumer.sh \
Hayvan koruma yerel ana bilgisayar:2181 \
–Takma adkullanıcılar \
–Emlak print.key =NS \
–Emlak anahtar.ayırıcı =, \
–Başlangıçtan beri
Gördüğünüz gibi, anahtar e değer Yeni eklenen çift kullanıcılarBaşlık blogger
yakalayacağım tüketici için program kullanıcılarBaşlık Bu terminalde ve diğer kullanıcılarda aç kullanıcılarBaşlık diğer taraftan terminal Ve ne olduğunu görün.
ile başka bir kullanıcı ekle anahtar 2 Aşağıdaki komutla:
$ Eko“2, {isim: ‘John Doe’, ülke: ‘BD’}”|sudo kafka-konsol-producer.sh
– Broker listesi yerel ana bilgisayar:9092 \
–Takma adkullanıcılar \
–Emlak ayrıştır.anahtar =NS \
–Emlak anahtar.ayırıcı =,
Aşağıdaki ekran görüntüsünde işaretlenen kısımdan da görebileceğiniz gibi yeni kullanıcı hemen tüketici programına dahil oluyor.
son kullanıcımızı ekleyelim anahtar 3 Aşağıdaki komutla:
$ Eko3, {isim: ‘Evelina Aquilino’, ülke: ‘ABD’}|sudo kafka-konsol-producer.sh
– Broker listesi yerel ana bilgisayar:9092 \
–Takma adkullanıcılar \
–Emlak ayrıştır.anahtar =NS \
–Emlak anahtar.ayırıcı =,
Gördüğünüz gibi yeni kullanıcı da listeye dahil edilmiştir. tüketici bir program.
Aynı anda birden fazla kullanıcı da ekleyebilirsiniz. yeminler. Sadece emin ol anahtar aynı.
Başka bir kullanıcı ekleyelim yeminler ile birlikte Anahtar 1:
$ Eko“1, {Ad: ‘Lynelle Piatt’, Ülke: ‘CA’}”|sudo kafka-konsol-producer.sh
– Broker listesi yerel ana bilgisayar:9092 \
–Takma adkullanıcılar \
–Emlak ayrıştır.anahtar =NS \
–Emlak anahtar.ayırıcı =,
Gördüğünüz gibi, yeni kullanıcı doğru bir şekilde eklendi. yeminler arasında Konu kullanıcıları.
Rastgele kullanıcılar eklemeye devam edebilirim kullanıcılarBaşlık Ve aşağıdaki ekran görüntüsünden de görebileceğiniz gibi doğru bölümden gönderilecektir.
öylemi yeminlerApache Kafka’da çalışır. Herşey yeminler gibi Sırabu bölümden gönderdiğiniz ilk mesaj ilk önce, ardından ikinci mesaj ve böylece gönderilme sırasına göre görüntülenir.
Eğer ben java geliştirici, kullanabilirsiniz java programlama dili ve Apache Kafka Java API’leriApache Kafka ile ilginç şeyler yapın yeminlers. Örneğin, farklı ayarlayabilirsiniz yeminler Anlık mesajlaşma uygulamanız için mesajların gönderildikleri sırayla görüntülenmesi gereken farklı sohbet odaları için.
Bugünlük bu kadar yeter. Bu makaleyi okuduğunuz için teşekkür ederiz.
Diğer gönderilerimize göz at
[wpcin-random-posts]
İlk Yorumu Siz Yapın