Phenquestions
Основи на дяловете Apache Kafka:
За да разберете основите на Apache Kafka Преградаs, трябва да знаете за Kafka Тема първо.
A Тема е като база данни в SQL база данни като MariaDB за Apache Kafka. A Тема има име или идентификатор, които използвате за групиране на съобщения в Apache Kafka.
A Преграда е като канал за всеки Тема. A Тема може да има много Преградаs или канали.
Мрежовият кабел, свързващ два компютъра, има два края, единият изпраща данни, а другият получава данни. Точно така, Apache Kafka Topic има два края, Продуцентпясък Консуматорс. A Продуцент създава съобщения и ги изпраща в един от Преградадиван Тема. A Консуматор от друга страна чете съобщенията от Преградадиван Тема.
Многократни Преградаs или канали са създадени за увеличаване на излишъка. Използва се и за групиране на съобщения в конкретен Тема.
Това са основите на Apache Kafka Преградас. Можете да научите повече за дяловете на Apache Kafka в друга специална статия Разделяне на Apache Kafka на https: // linuxhint.com / apache-kafka-разделяне
Инсталиране на Apache Kafka:
Имам специална подробна статия за това как Инсталирайте Apache Kafka на Ubuntu, които можете да прочетете на https: // linuxhint.com / install-apache-kafka-ubuntu /
С малко ощипвания можете да инсталирате Apache Kafka и на други Linux дистрибуции.
Стартиране на Apache Kafka сървър:
Ако сте следвали статията ми, за да инсталирате Apache Kafka, първо стартирайте сървъра Apache Kafka със следната команда:
$ sudo kafka-server-start.sh / etc / kafka.ИмотиСървърът на Apache Kafka трябва да се стартира. Дръжте този терминал отворен, стига да искате сървърът на Apache Kafka да работи.
Създаване на тема Apache Kafka:
Можете да създадете Apache Kafka Тема тестване със следната команда:
$ sudo kafka-теми.ш--създаване \
--zookeeper localhost: 2181 \
--фактор на репликация 1 \
--дялове 1 \
--тестване на теми
The Тема тестване трябва да се създаде. Това Тема има 1 дял.
Ако искате да създавате, да кажем н дялове, след това задайте -дялове да се н.
Нека създадем друга Тема, да речем потребители, с 3 Преградаs, след това изпълнете следната команда:
$ sudo kafka-теми.ш--създаване \
--zookeeper localhost: 2181 \
--фактор на репликация 1 \
--дялове 3 \
--потребители на теми
Потребители на теми трябва да се създаде с 3 Преградас.
Добавяне на разделени съобщения към темата:
A Преградаed съобщение на a Тема има ключ и а стойност. The ключ и стойност обикновено се разделя с a запетая или друг специален знак. Няма значение какъв специален символ използвате, за да разделите ключ и стойност двойка. Но навсякъде трябва да използвате един и същ специален знак Тема. В противен случай нещата може да се объркат.
The ключ се използва за определяне на кой Преграда съобщение на a Тема принадлежи на. Тя трябва да бъде уникална за Тема. Ако имате 3 Преградаs, тогава трябва да използвате 3 различен ключс. За да могат съобщенията да се разделят на 3 Преградас.
Да кажем нашите потребители Тема има 3 потребители с ключ 1, 2, и 3, всеки от тях принадлежи на един от 3 Преградаs на потребители Тема.
Изпълнете следната команда, за да добавите първия потребител с ключ 1 използвайки API на Kafka Producer:
$ echo "1, name: 'Shahriar Shovon', country: 'BD'" | sudo kafka-производител на конзоли.ш--списък с брокери localhost: 9092 \
--потребители на тема \
--разбор на имота.ключ = вярно \
--ключ на свойството.разделител =,
Сега можете да изброите съобщението от потребители Тема използвайки Потребителски API на Kafka със следната команда:
$ sudo kafka-console-consumer.ш--zookeeper localhost: 2181 \
--потребители на тема \
--собственост печат.ключ = вярно \
--ключ на свойството.разделител =, \
--от началото
Както можете да видите, ключ и стойност чифт, който току-що добавих към потребители Тема е в списъка.
Аз ще запазя Консуматор програма за потребители Тема отворете на този терминал и добавете останалите потребители към потребители Тема от друг Терминал и вижте какво ще се случи.
Добавете друг потребител с клавиш 2 със следната команда:
$ echo "2, name: 'John Doe', country: 'BD'" | sudo kafka-производител на конзоли.ш--списък с брокери localhost: 9092 \
--потребители на тема \
--разбор на имота.ключ = вярно \
--ключ на свойството.разделител =,
Както можете да видите от маркирания раздел на екранната снимка по-долу, новият потребител е включен незабавно в потребителската програма.
Нека добавим нашия последен потребител с ключ 3 със следната команда:
$ echo "3, name: 'Evelina Aquilino', country: 'US'" | sudo kafka-производител на конзоли.ш--списък с брокери localhost: 9092 \
--потребители на тема \
--разбор на имота.ключ = вярно \
--ключ на свойството.разделител =,
Както можете да видите, новият потребител също е посочен в Консуматор програма.
Можете също да добавите много потребители към същия Преграда. Просто се уверете, че ключ е същото.
Нека добавим друг потребител към Преграда с ключ 1:
$ echo "1, name: 'Lynelle Piatt', country: 'CA'" | sudo kafka-производител на конзоли.ш--списък с брокери localhost: 9092 \
--потребители на тема \
--разбор на имота.ключ = вярно \
--ключ на свойството.разделител =,
Както можете да видите, новият потребител се добавя към правилния Преграда от потребители Тема.
Мога да продължа да добавя произволни потребители към потребители Тема и те ще бъдат изпратени през правилния дял, както можете да видите от екранната снимка по-долу.
Така че това е как Преградаs в Apache Kafka работи. Всеки Преграда е като a Опашка, първото съобщение, което изпращате през този дял, се показва първо, а след това второто съобщение и така нататък в реда, в който са изпратени.
Ако сте Java разработчик, можете да използвате Java език за програмиране и API на Apache Kafka Javaда правите интересни неща с Apache Kafka Преградас. Например можете да зададете различни Преграда за различни стаи за чат за вашето приложение за незабавни съобщения, тъй като съобщенията трябва да се показват в реда, в който са изпратени.
Това е всичко за днес. Благодаря ви, че прочетохте тази статия.
