Почетак рада са Апацхе Кафком
Пре инсталирања Апацхе Кафке, морате имати инсталирану Јава и кориснички налог са судо привилегијама. Штавише, препоручује се да имате РАМ од 2 ГБ и више за правилно функционисање Кафке.
Следећи кораци ће вас упутити како да инсталирате Апацхе Кафка.
Инсталирање Јаве
Јава је неопходна за инсталирање Кафке. Проверите да ли ваш Убунту има инсталирану Јаву тако што ћете проверити верзију помоћу следеће команде:
$ јава --версион
Ако Јава није инсталирана, користите следеће команде да бисте инсталирали Јава ОпенЈДК.
$ судо погодан инсталирај дефаулт-јдк
Креирање корисничког налога
Са већ инсталираном Јавом, направите кориснички налог који није роот. Такође морамо да му дамо неке судо привилегије додавањем корисника у судо групу помоћу следеће команде:
$ судо аддусер линукхинт
$ судо аддусер линукхинт судо
Пријавите се на новоотворени кориснички налог.
Инсталирање Кафке
Морате да преузмете најновији Апацхе Кафка са званичне странице за преузимање. Преузмите његове бинарне датотеке користећи вгет команду као што је приказано у наставку:
$ вгет хттпс: // довнлоадс.апацхе.орг / кафка / 3.2.3 / кафка_2.12-3.2.3.тгз 
Када се бинарна датотека преузме, распакујте је помоћу узима команду и померите извучени директоријум у /опт/кафка.
Затим креирајте системд скрипте за Зоокеепер анд тхе Кафка услуге које помажу у покретању и заустављању услуга.
Користите уређивач по избору да креирате системд скрипте и налепите следећи садржај. Почните са Зоокеепер-ом:
$ судо нано / итд / системд / система / чувар зоолошког врта.службаНалепите следеће:
[ Јединица ]Опис =Апацхе Зоокеепер сервер
Документација =хттп: // зоокеепер.апацхе.орг
Захтева =нетворк.таргет ремоте-фс.таргет
После =нетворк.таргет ремоте-фс.таргет
[ Услуга ]
Тип =једноставно
ЕкецСтарт = / опт / кафка / бин / зоокеепер-сервер-старт.сх / опт / кафка / цонфиг / чувар зоолошког врта.особине
ЕкецСтоп = / опт / кафка / бин / зоокеепер-сервер-стоп.сх
Поново покренути =он-абнормал
[ Инсталирај ]
ВантедБи =мулти-усер.таргет
Сачувајте датотеку. Креирајте системд датотеку за Кафку и налепите следећи садржај:
Када налепите, уверите се да сте поставили праву путању за Јаву коју сте инсталирали у свој систем.
[ Јединица ]Опис =Апацхе Кафка сервер
Документација =хттп: // кафка.апацхе.орг / документација.хтмл
Захтева =зоокеепер.сервице
[ Услуга ]
Тип =једноставно
Животна средина = „ЈАВА_ХОМЕ=/уср/либ/јвм/јава-11-опењдк-амд64“
ЕкецСтарт = / опт / кафка / бин / кафка-сервер-старт.сх / опт / кафка / цонфиг / сервер.пропертиес
ЕкецСтоп = / опт / кафка / бин / кафка-сервер-стоп.сх
Поново покренути =он-абнормал
[ Инсталирај ]
ВантедБи =мулти-усер.таргет
Када завршите, примените промене поновним учитавањем системд демона:
Затим омогућите услугу Зоокеепер и покрените је помоћу следећих команди:
$ судо системцтл старт зоокеепе < јака > р јака >
Исто треба да урадите и за Кафку:
$ судо системцтл старт кафка
Када покренете услуге, можете да проверите њихов статус пре него што креирамо тему у Кафки.
Добра ствар код Кафке је што постоји више скрипти које можете да користите.
Хајде да направимо нову тему под називом линукхинт1 помоћу кафка-топицс.сх скрипта са једном партицијом и репликацијом. Користите следећу команду:
$ судо -ин линукхинт / опт / кафка / бин / кафка-топицс.сх --Креирај --боотстрап-сервер локални домаћин: 9092 --фактор репликације 1 --партиције 1 --топиц линукхинт1 
Имајте на уму да је наша тема креирана. Можемо да видимо претходну поруку да то потврдимо.
Алтернативно, можете навести доступне теме помоћу -листа опцију у следећој команди. Требало би да врати тему коју смо направили: С
$ судо -ин линукхинт / опт / кафка / бин / кафка-топицс.сх --листа --боотстрап-сервер локални домаћин: 9092 
Са креирањем теме Кафка, можете почети да пишете податке о стримовима на Кафка-цонсоле-продуцер.сх и проверите да ли се одражава у вашем потрошач.ш.
Отворите своју љуску и приступите теми коју смо креирали користећи продуцер.сх као што је приказано у наставку:
$ судо -ин линукхинт / опт / кафка / бин / кафка-цонсоле-продуцер.сх --брокер-лист локални домаћин: 9092 --топиц линукхинт1 
Затим отворите другу љуску и приступите теми Кафка користећи Цонсумер.сх.
Када су отворене две шкољке, можете слати поруке на конзоли произвођача. Шта год да унесете, одражава се на потрошачкој конзоли потврђујући да је наш Апацхе Кафка покренут и ради.
Закључак
Уз овај водич, сада имате све кораке које можете пратити да бисте инсталирали Апацхе Кафка у свој Убунту 22.04. Надамо се да сте успели да пратите сваки корак и инсталирате своју Апацхе Кафку и креирате теме за покретање једноставне производње за потрошаче и произвођаче. Исто можете имплементирати у великој производњи.