Phenquestions
Основы разделов Apache Kafka:
Чтобы понять основы Apache Kafka Разделs, вам нужно знать о Кафке Тема первый.
А Тема похожа на базу данных в базе данных SQL, например MariaDB для Apache Kafka. А Тема имеет имя или идентификатор, который вы используете для группировки сообщений в Apache Kafka.
А Раздел как канал для каждого Тема. А Тема может иметь много Разделs или каналы.
Сетевой кабель, соединяющий два компьютера, имеет два конца, один для отправки данных, другой для приема данных. Таким образом, Apache Kafka Topic имеет два конца, Режиссерпесок Потребительs. А Режиссер создает сообщения и отправляет их в одном из Разделс Тема. А Потребитель с другой стороны читает сообщения от Разделс Тема.
Несколько Разделs или каналы созданы для увеличения избыточности. Он также используется для группировки сообщений в определенном Тема.
Это основы Apache Kafka Разделs. Вы можете узнать больше о разделах 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 кафка-сервер-старт.ш / и т. д. / кафка.характеристикиСервер Apache Kafka должен запуститься. Держите этот терминал открытым до тех пор, пока вы хотите, чтобы сервер Apache Kafka работал.
Создание темы Apache Kafka:
Вы можете создать Apache Kafka Тема тестирование с помощью следующей команды:
$ sudo kafka-themes.ш \--Создайте \
--zookeeper localhost: 2181 \
--фактор репликации 1 \
--перегородки 1 \
--тематическое тестирование
В Тема тестирование должен быть создан. Этот Тема имеет 1 раздел.
Если вы хотите создать, скажем N перегородки, затем установите -перегородки к N.
Создадим еще один Тема, скажем пользователи, с участием 3 Разделs, затем выполните следующую команду:
$ sudo kafka-themes.ш \--Создайте \
--zookeeper localhost: 2181 \
--фактор репликации 1 \
--перегородки 3 \
--пользователи темы
Пользователи темы должен быть создан с 3 Разделs.
Добавление сообщений в тему:
А Разделed сообщение Тема имеет ключ и значение. В ключ а также значение обычно разделяется запятая или другой специальный символ. Неважно, какой специальный символ вы используете для разделения ключ а также значение пара. Но вы должны везде использовать один и тот же специальный символ Тема. В противном случае все могло пойти не так.
В ключ используется, чтобы определить, какой Раздел сообщение Тема принадлежит. Он должен быть уникальным на Тема. Если у тебя есть 3 Разделs, тогда вам следует использовать 3 разные ключs. Так что сообщения можно разделить на 3 Разделs.
Скажем, наш пользователи Тема имеет 3 пользователи с ключ 1, 2, а также 3, каждый из них принадлежит к одному из 3 Разделс из Пользователи Тема.
Выполните следующую команду, чтобы добавить первого пользователя с ключ 1 с помощью Kafka Producer API:
$ echo "1, имя: 'Шахриар Шовон', страна: 'BD'" | Судо Кафка-консоль-производитель.ш \--список брокеров localhost: 9092 \
--пользователи темы \
--анализ собственности.ключ = истина \
--ключ собственности.разделитель =,
Теперь вы можете перечислить сообщение из пользователи Тема с помощью Потребительский API Kafka с помощью следующей команды:
$ судо кафка-консоль-потребитель.ш \--zookeeper localhost: 2181 \
--пользователи темы \
--печать собственности.ключ = истина \
--ключ собственности.разделитель =, \
--с начала
Как видите, ключ а также значение пара, которую я только что добавил в пользователи Тема перечислен.
Я собираюсь сохранить Потребитель программа для пользователи Тема открыть в этом Терминале и добавить других пользователей в пользователи Тема От другого Терминал и посмотрим, что произойдет.
Добавить другого пользователя с ключ 2 с помощью следующей команды:
$ echo "2, имя: 'Джон Доу', страна: 'BD'" | Судо Кафка-консоль-производитель.ш \--список брокеров localhost: 9092 \
--пользователи темы \
--анализ собственности.ключ = истина \
--ключ собственности.разделитель =,
Как видно из отмеченного раздела на скриншоте ниже, новый пользователь мгновенно отображается в потребительской программе.
Давайте добавим нашего последнего пользователя с ключ 3 с помощью следующей команды:
$ echo "3, имя: 'Эвелина Акилино', страна: 'США'" | Судо Кафка-консоль-производитель.ш \--список брокеров localhost: 9092 \
--пользователи темы \
--анализ собственности.ключ = истина \
--ключ собственности.разделитель =,
Как видите, новый пользователь также указан в списке Потребитель программа.
Вы также можете добавить много пользователей к одному и тому же Раздел. Просто убедитесь, что ключ та же.
Добавим еще одного пользователя в Раздел с участием ключ 1:
$ echo "1, имя: 'Линель Пиат', страна: 'CA'" | Судо Кафка-консоль-производитель.ш \--список брокеров localhost: 9092 \
--пользователи темы \
--анализ собственности.ключ = истина \
--ключ собственности.разделитель =,
Как видите, новый пользователь добавлен в правильный Раздел принадлежащий Пользователи Тема.
Я могу добавлять случайных пользователей в пользователи Тема и они будут отправлены через правильный раздел, как вы можете видеть на скриншоте ниже.
Так вот как Разделs в Apache Kafka работает. Каждый Раздел похоже на Очередь, сначала отображается первое сообщение, которое вы отправляете через этот раздел, а затем второе сообщение и т. д. в порядке их отправки.
Если ты Ява разработчик, вы можете использовать Ява язык программирования и API Java Apache Kafkas делать интересные вещи с Apache Kafka Разделs. Например, вы можете назначить разные Раздел для разных чатов для вашего приложения для обмена мгновенными сообщениями, поскольку сообщения должны отображаться в порядке их отправки.
Так что на сегодня все. Спасибо, что прочитали эту статью.
