Phenquestions
Asas Partisi Apache Kafka:
Untuk memahami asas-asas Apache Kafka Partitions, anda perlu tahu mengenai Kafka Topik pertama.
A Topik seperti pangkalan data dalam pangkalan data SQL seperti MariaDB untuk Apache Kafka. A Topik mempunyai nama atau pengecam yang anda gunakan untuk mengelompokkan mesej di Apache Kafka.
A Partition adalah seperti saluran untuk masing-masing Topik. A Topik boleh mempunyai banyak Partitions atau saluran.
Kabel rangkaian yang menghubungkan dua komputer mempunyai dua hujung, yang satu mengirim data, yang lain menerima data. Sama seperti itu, Apache Kafka Topik mempunyai dua hujung, Penerbits dan Penggunas. A Penerbit membuat mesej, dan menghantarnya di salah satu Partitions dari a Topik. A Pengguna sebaliknya membaca mesej dari Partitions dari a Topik.
Pelbagai Partitions atau saluran dibuat untuk meningkatkan kelebihan. Ini juga digunakan untuk mengelompokkan mesej secara khusus Topik.
Itulah asas-asas Apache Kafka Partitions. Anda boleh mengetahui lebih lanjut mengenai partisi Apache Kafka pada artikel khusus yang lain Pembahagian Apache Kafka di https: // linuxhint.com / apache-kafka-partitioning
Memasang Apache Kafka:
Saya mempunyai artikel terperinci khusus untuk bagaimana Pasang Apache Kafka di Ubuntu, yang boleh anda baca di https: // linuxhint.com / pasang-apache-kafka-ubuntu /
Dengan sedikit perubahan, anda boleh memasang Apache Kafka pada pengedaran Linux yang lain juga.
Memulakan Pelayan Apache Kafka:
Sekiranya anda mengikuti artikel saya untuk memasang Apache Kafka, mulakan dahulu pelayan Apache Kafka dengan arahan berikut:
$ sudo kafka-pelayan-mulakan.sh / etc / kafka.harta bendaPelayan Apache Kafka harus dimulakan. Pastikan terminal ini terbuka selagi anda mahu pelayan Apache Kafka dijalankan.
Membuat Topik Apache Kafka:
Anda boleh membuat Apache Kafka Topik ujian dengan arahan berikut:
$ sudo kafka-topik.sh \--buat \
--hos tempatan penjaga pintu: 2181 \
--faktor replikasi 1 \
--partition 1 \
--ujian topik
The Topik ujian harus dibuat. Ini Topik mempunyai 1 partition.
Sekiranya anda mahu membuat, katakan N partition, kemudian tetapkan -partition ke N.
Mari buat yang lain Topik, katakan pengguna, dengan 3 Partitions, kemudian jalankan arahan berikut:
$ sudo kafka-topik.sh \--buat \
--hos tempatan: 2181 \
--faktor replikasi 1 \
--partition 3 \
--pengguna topik
Pengguna topik harus dibuat dengan 3 Partitions.
Menambah Mesej Berpisah ke Topik:
A Partitionpesanan ed dari a Topik mempunyai kunci dan a nilai. The kunci dan nilai biasanya dipisahkan oleh a koma atau watak khas lain. Tidak kira watak khas apa yang anda gunakan untuk memisahkan kunci dan nilai berpasangan. Tetapi anda mesti menggunakan watak khas yang sama di mana sahaja Topik. Jika tidak, perkara boleh menjadi salah.
The kunci digunakan untuk menentukan yang mana Partition pesanan a Topik kepunyaan. Ia mesti unik pada a Topik. Jika anda mempunyai 3 Partitions, maka anda harus menggunakan 3 berbeza kuncis. Supaya mesej dapat dibahagikan kepada 3 Partitions.
Katakanlah kami pengguna Topik telah 3 pengguna dengan kunci 1, 2, dan 3, masing-masing tergolong dalam salah satu 3 Partitiondari Topik pengguna.
Jalankan arahan berikut untuk menambahkan pengguna pertama dengan kunci 1 menggunakan API Pengeluar Kafka:
$ echo "1, name: 'Shahriar Shovon', negara: 'BD'" | sudo kafka-konsol-pengeluar.sh \--senarai tempatan localhost: 9092 \
--pengguna topik \
--menguraikan harta benda.kunci = benar \
--kunci harta benda.pemisah =,
Sekarang anda boleh menyenaraikan mesej dari pengguna Topik menggunakan API Pengguna Kafka dengan arahan berikut:
$ sudo kafka-konsol-pengguna.sh \--hos tempatan: 2181 \
--pengguna topik \
--cetakan harta tanah.kunci = benar \
--kunci harta benda.pemisah =, \
--dari awal
Seperti yang anda lihat, kunci dan nilai pasangan yang baru saya tambah ke pengguna Topik disenaraikan.
Saya akan menjaga Pengguna program untuk pengguna Topik buka di Terminal ini dan tambahkan pengguna lain ke pengguna Topik dari yang lain Terminal dan lihat apa yang berlaku.
Tambahkan pengguna lain dengan kunci 2 dengan arahan berikut:
$ echo "2, name: 'John Doe', negara: 'BD'" | sudo kafka-konsol-pengeluar.sh \--senarai tempatan localhost: 9092 \
--pengguna topik \
--menguraikan harta benda.kunci = benar \
--kunci harta benda.pemisah =,
Seperti yang anda lihat dari bahagian tangkapan skrin di bawah, pengguna baru akan disenaraikan dalam program Pengguna dengan serta-merta.
Mari tambah pengguna terakhir kami dengan kunci 3 dengan arahan berikut:
$ echo "3, name: 'Evelina Aquilino', negara: 'US'" | sudo kafka-konsol-pengeluar.sh \--senarai tempatan localhost: 9092 \
--pengguna topik \
--menguraikan harta benda.kunci = benar \
--kunci harta benda.pemisah =,
Seperti yang anda lihat, pengguna baru juga disenaraikan di Pengguna program.
Anda juga boleh menambah banyak pengguna yang sama Partition. Pastikan sahaja kunci adalah sama.
Mari tambahkan pengguna lain ke Partition dengan kunci 1:
$ echo "1, name: 'Lynelle Piatt', negara: 'CA'" | sudo kafka-konsol-pengeluar.sh \--senarai tempatan localhost: 9092 \
--pengguna topik \
--menguraikan harta benda.kunci = benar \
--kunci harta benda.pemisah =,
Seperti yang anda lihat, pengguna baru ditambahkan ke yang betul Partition daripada Topik pengguna.
Saya boleh terus menambahkan pengguna rawak ke pengguna Topik dan mereka akan dihantar melalui partisi yang betul seperti yang anda lihat dari tangkapan skrin di bawah.
Jadi begitulah Partitions di Apache Kafka berfungsi. Setiap Partition adalah seperti a Beratur, mesej pertama yang anda hantar melalui partisi itu dipaparkan terlebih dahulu, dan kemudian mesej kedua dan seterusnya mengikut urutan ia dihantar.
Sekiranya anda seorang Jawa pemaju, anda boleh menggunakan Jawa bahasa pengaturcaraan dan API Java Apache Kafkauntuk melakukan perkara menarik dengan Apache Kafka Partitions. Sebagai contoh, anda boleh menetapkan yang berbeza Partition untuk ruangan sembang yang berbeza untuk aplikasi pesanan segera anda kerana mesej mesti dipaparkan mengikut pesanan yang dihantar.
Jadi itu sahaja untuk hari ini. Terima kasih kerana membaca artikel ini.
