Инсталирање Апацхе Кафке
Прво ажурирајте кеш спремишта пакета вашег Убунту сервера следећом наредбом:
$ судо апт-гет упдате
Кеш спремишта спремишта пакета треба ажурирати.
Апацхе Кафка зависи од Јаве. Можете да инсталирате ОпенЈДК 8 на Убунту 17.10 из званичног спремишта пакета.
Покрените следећу команду да бисте инсталирали ОпенЈДК 8 на Убунту 17.10:
$ судо апт-гет инсталирај опењдк-8-јдк
Сада притисните „и“, а затим притисните
Треба инсталирати ОпенЈДК 8.
Сада морате да инсталирате чувар зоолошког врта. Доступан је у службеном спремишту пакета Убунту-а.
За инсталацију чувар зоолошког врта, покрените следећу команду:
$ судо апт-гет инсталл зоокееперд
Сада притисните „и“, а затим притисните
чувар зоолошког врта треба инсталирати.
Можете покренути следећу команду да бисте проверили да ли чувар зоолошког врта трчи:
$ судо системцтл статус чувар зоолошког вртаКао што можете видети са снимка заслона испод, чувар зоолошког врта трчи.
Ако из неког разлога не ради на вашој машини, можете започети чувар зоолошког врта са следећом командом:
$ судо системцтл покрени чувара зоолошког врта
Требали бисте додати чувар зоолошког врта до покретања система. Дакле, аутоматски ће се покренути приликом покретања.
Покрените следећу команду за додавање чувар зоолошког врта до покретања система:
$ судо системцтл омогућава зоокеепер
чувар зоолошког врта треба додати у покретање система као што можете видети са снимка заслона испод.
треба ми нетстат команду коју пружа мрежни алати пакет.
Сада инсталирајте мрежни алати пакет са следећом командом:
$ судо апт-гет инсталл нет-тоолс
мрежни алати пакет треба инсталирати.
Сада можете покренути следећу команду да бисте проверили да ли зоокеепер ради на порту 2181.
$ судо нетстат -тулпен | греп 2181Као што видите, покренут је на порту 2181.
Сада покрените следећу наредбу за навигацију до директорија ~ / Довнлоадс / у директоријуму ХОМЕ ваших корисника:
$ цд ~ / Преузимања
Сада морате да преузмете Апацхе Кафка. У време писања овог чланка, најновија верзија Апацхе Кафке је в1.0.0.
Покрените следећу команду да бисте преузели Апацхе Кафка 1.0.0 со вгет:
$ вгет хттп: // ввв-еу.апацхе.орг / дист / кафка / 1.0.0 / кафка_2.12-1.0.0.тгз
Компресовану архиву Апацхе Кафка треба преузети.
Као што видите из излаза лс наредбе, назив датотеке Апацхе Кафка архиве је кафка_2.12-1.0.0.тгз
Сада креирајте директоријум Кафка / у / опт директоријум са следећом наредбом:
$ судо мкдир / опт / КафкаДиректориј / опт / Кафка треба створити. Овде ћу извући архиву.
Сада извуците архиву Апацхе Кафка у / опт / Кафка директоријум са следећом наредбом:
$ судо тар квзф кафка_2.12-1.0.0.тгз -Ц / опт / Кафка
Архиву треба издвојити.
Можете да покренете следећу команду да бисте проверили име директоријума:
$ лс / опт / КафкаОбратите пажњу на то име директоријума.
Отворен / етц / профиле са следећом командом:
$ судо нано / етц / профиле
Додајте следеће редове на крај датотеке и сачувајте је.
Сада отворите ~ /.басхрц датотека са следећом наредбом:
$ судо нано ~ /.басхрц
Додајте означену линију на крај датотеке како бисте је сачували.
Сада поново покрените рачунар следећом командом:
$ судо ребоот
Једном када се рачунар покрене, можете проверити да ли су променљиве окружења додате на следећи начин:
$ ецхо $ КАФКА_ХОМЕ$ ецхо $ ПАТХ
Сада, како бисте нам олакшали живот, направите симболичну везу Кафке сервер.својства датотека на следећи начин:
$ судо лн -с $ КАФКА_ХОМЕ / цонфиг / сервер.својства / етц / кафка.својства
Као што можете видети са снимка заслона испод, створена је симболична веза.
Сада Апацхе Кафка сервер можете покренути следећом наредбом:
$ судо кафка-сервер-старт.сх / етц / кафка.својства
Апацхе Кафка сервер треба покренути.
Тестирање Апацхе Кафка сервера
Можете направити тест тему тестирање на Апацхе Кафка серверу следећом командом:
$ судо кафка-теме.сх --цреате --зоокеепер лоцалхост: 2181 - фактор репликације 1--партиције 1 - тестирање теме
А тестирање Тема треба да се креира како је приказано на снимку екрана испод.
Сада покрените следећу наредбу да бисте користили Кафка Продуцер АПИ за слање неке поруке на тестирање тема:
$ судо кафка-произвођач конзола.сх --брокер-лист лоцалхост: 9092 - тестирање тема
Једном када притиснете
Само укуцајте нешто и притисните
Сада можете да користите Кафка Цонсумер АПИ за преузимање порука / линија са тестирање тема са следећом командом:
$ судо кафка-конзола-потрошач.сх --зоокеепер лоцалхост: 2181 --тестирање теме - од почетка
Требали бисте бити у могућности да видите поруке или редове које сте написали помоћу АПИ-ја произвођача, како је означено на снимку заслона испод.
Ако нову поруку напишете помоћу АПИ-ја произвођача, она би такође требала бити одмах приказана на страни Потрошач, као што је приказано на снимку заслона испод.
Дакле, тако инсталирате Апацхе Кафка и проверите да ли ради на Убунту 17.10 Уметан Аардварк. Хвала што сте прочитали овај чланак.