Начало работы с Apache Kafka
Перед установкой Apache Kafka у вас должна быть установлена Java и учетная запись пользователя с привилегиями sudo. Кроме того, для правильной работы Kafka рекомендуется иметь оперативную память от 2 ГБ и выше.
Следующие шаги помогут вам установить Apache Kafka.
Установка Java
Для установки Kafka требуется Java. Проверьте, установлена ли на вашем Ubuntu Java, проверив версию с помощью следующей команды:
$ Ява --версия
Если Java не установлена, используйте следующие команды для установки Java OpenJDK.
$ судо подходящий установить по умолчанию-jdk
Создание учетной записи пользователя
Если Java уже установлена, создайте учетную запись пользователя без полномочий root. Нам также нужно предоставить ему некоторые привилегии sudo, добавив пользователя в группу sudo с помощью следующей команды:
$ судо добавочный пользователь
$ судо добавочный пользователь судо
Войдите в только что созданную учетную запись пользователя.
Установка Кафки
Вам необходимо загрузить последнюю версию Apache Kafka с официальной страницы загрузки. Загрузите его бинарные файлы с помощью wget команду, как показано ниже:
$ wget https: // Downloads.apache.org / кафка / 3.2.3 / кафка_2.12-3.2.3.tgz 
После загрузки бинарного файла извлеките его с помощью команды берет команду и переместите извлеченный каталог в /опт/кафка.
Далее создайте системные скрипты для Работник зоопарка и Кафка сервисы, которые помогают запускать и останавливать сервисы.
Используйте любой редактор для создания сценариев systemd и вставьте следующее содержимое. Начните с Zookeeper:
$ судо нано / так далее / системад / система / зоопарк.сервисВставьте следующее:
[ Ед. изм ]Описание = сервер Apache Zookeeper
Документация =http: // zookeeper.apache.org
Требует = сеть.цель удаленная-fs.цель
После = сеть.цель удаленная-fs.цель
[ обслуживание ]
Тип = простой
ExecStart знак равно / выбрать / кафка / мусорное ведро / zookeeper-сервер-start.sh / выбрать / кафка / конфигурация / zookeeper.properties
ExecStop знак равно / выбрать / кафка / мусорное ведро / zookeeper-сервер-stop.sh
Запустить снова = ненормальный
[ Установить ]
WantedBy =многопользовательская.цель
Сохраните файл. Создайте файл systemd для Kafka и вставьте следующее содержимое:
При вставке убедитесь, что вы указали правильный путь для Java, установленного в вашей системе.
[ Ед. изм ]Описание = Сервер Apache Kafka
Документация =http: // kafka.apache.org / документация.html
Требует =zookeeper.service
[ обслуживание ]
Тип = простой
Окружающая среда знак равно 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart знак равно / выбрать / кафка / мусорное ведро / кафка-сервер-start.sh / выбрать / кафка / конфигурация / сервер.свойства
ExecStop знак равно / выбрать / кафка / мусорное ведро / кафка-сервер-stop.sh
Запустить снова = ненормальный
[ Установить ]
WantedBy =многопользовательская.цель
После этого примените изменения, перезагрузив демон systemd:
Затем включите службу Zookeeper и запустите ее с помощью следующих команд:
$ судо systemctl запустить зоопарк < сильный > р сильный >
Вам также нужно сделать то же самое для Кафки:
$ судо systemctl запустить кафку
После запуска сервисов вы можете проверить их статус, прежде чем мы создадим тему в Kafka.
Хорошая вещь с Kafka заключается в том, что вы можете использовать несколько сценариев.
Создадим новую тему с названием линуксхинт1 с использованием кафка-topics.sh скрипт с одним разделом и репликацией. Используйте следующую команду:
$ судо -в линуксинт / выбрать / кафка / мусорное ведро / кафка-topics.sh --Создайте --bootstrap-сервер локальный хост: 9092 --фактор репликации 1 --partitions 1 --тема линуксхинт1 
Обратите внимание, что наша тема создана. Мы можем увидеть предыдущее сообщение, чтобы убедиться в этом.
Кроме того, вы можете перечислить доступные темы, используя -список параметр в следующей команде. Он должен вернуть тему, которую мы создали :S
$ судо -в линуксинт / выбрать / кафка / мусорное ведро / кафка-topics.sh --список --bootstrap-сервер локальный хост: 9092 
Создав тему Kafka, вы можете начать записывать данные потоков на Kafka-console-producer.sh и проверьте, отражается ли это на вашем потреб.ш.
Откройте вашу оболочку и получите доступ к теме, которую мы создали с помощью производителя.sh, как показано ниже:
$ судо -в линуксинт / выбрать / кафка / мусорное ведро / кафка-консоль-производитель.ш --брокер-список локальный хост: 9092 --тема линуксхинт1 
Затем откройте другую оболочку и получите доступ к теме Kafka с помощью Consumer.sh.
Открыв две оболочки, вы можете отправить сообщение на консоль производителя. Все, что вы вводите, отражается в пользовательской консоли, подтверждая, что наш Apache Kafka запущен и работает.
Вывод
С помощью этого руководства у вас теперь есть все шаги, которые вы можете выполнить, чтобы установить Apache Kafka в Ubuntu 22.04. Надеюсь, вам удалось выполнить каждый шаг, установить Apache Kafka и создать темы для запуска простого производства потребителей и производителей. Вы можете реализовать то же самое в большом производстве.