Апацхе Кафка је моћан сервис посредника порука. Веома је брз и поуздан. Апацхе Кафка је отворени извор и бесплатан за употребу. Написано је на Јави.У овом чланку ћу вам показати како да подесите партиције у Апацхе Кафка. Хајде да почнемо.

Основе Апацхе Кафка партиција:

Да бисте разумели основе Апача Кафке Поделас, морате знати о Кафки Тема први.

А Тема је попут базе података у СКЛ бази података као што је МариаДБ за Апацхе Кафка. А Тема има име или идентификатор који користите за груписање порука у Апацхе Кафка.

А Подела је као канал за сваког Тема. А Тема може имати много Поделаили канале.

Мрежни кабл који повезује два рачунара има два краја, један шаље податке, а други прима податке. Баш тако, Апацхе Кафка Топиц има два краја, Продуцентпесак Потрошачс. А Продуцент креира поруке и шаље их у један од ПоделаСофа Тема. А Потрошач с друге стране чита поруке из ПоделаСофа Тема.

Вишеструко Поделас или канали су створени да повећају сувишност. Такође се користи за груписање порука у одређену Тема.

То је основа Апацхе Кафке Поделас. Можете сазнати више о Апацхе Кафка партицијама у другом наменском чланку Апацхе Кафка партиционирање на хттпс: // линукхинт.цом / апацхе-кафка-партиционирање

Инсталирање Апацхе Кафка:

Имам посвећен детаљан чланак о томе како Инсталирајте Апацхе Кафка на Убунту, које можете прочитати на хттпс: // линукхинт.цом / инсталл-апацхе-кафка-убунту /

Уз мало подешавања, можете инсталирати Апацхе Кафка и на друге Линук дистрибуције.

Покретање Апацхе Кафка сервера:

Ако сте пратили мој чланак да бисте инсталирали Апацхе Кафка, прво покрените Апацхе Кафка сервер следећом наредбом:

$ судо кафка-сервер-старт.сх / етц / кафка.својства

Апацхе Кафка сервер треба да се покрене. Држите овај терминал отворен све док желите да Апацхе Кафка сервер ради.

Стварање Апацхе Кафка теме:

Можете створити Апацхе Кафка Тема тестирање са следећом командом:

$ судо кафка-теме.сх \
--Креирај \
--зоокеепер лоцалхост: 2181 \
--фактор репликације 1 \
--партиције 1 \
--тестирање теме

Тхе Тема тестирање треба створити. Ово Тема има 1 партицију.

Ако желите да стварате, рецимо Н партиције, затим поставите -преграде до Н.

Створимо другу Тема, рецимо корисника, са 3 Поделас, а затим покрените следећу команду:

$ судо кафка-теме.сх \
--Креирај \
--зоокеепер лоцалхост: 2181 \
--фактор репликације 1 \
--партиције 3 \
--корисници теме

Корисници тема треба створити са 3 Поделас.

Додавање партиционираних порука у тему:

А Поделаед порука а Тема има кључ и а вредност. Тхе кључ и вредност је обично одвојено а зарез или другог посебног карактера. Није важно који посебан знак користите за одвајање кључ и вредност пар. Али свуда на томе морате користити исти специјални знак Тема. У супротном ствари могу кренути по злу.

Тхе кључ користи се за одређивање којих Подела порука а Тема припада. Требало би да буде јединствено на Тема. Ако имате 3 Поделас, онда бисте требали да користите 3 различит кључс. Тако да се поруке могу поделити на 3 Поделас.

Рецимо наше корисника Тема има 3 корисници са тастер 1, 2, и 3, сваки од њих припада једном од 3 Поделас оф корисници Тема.

Покрените следећу команду да бисте додали првог корисника тастер 1 помоћу Кафка Продуцер АПИ:

$ ецхо "1, наме: 'Схахриар Сховон', цоунтри: 'БД'" | судо кафка-произвођач конзола.сх \
--брокер-лист лоцалхост: 9092 \
--корисници теме \
--рашчлањивање имовине.кеи = труе \
--кључ својства.сепаратор =,

Сада можете да наведете поруку из корисника Тема помоћу Кафка Цонсумер АПИ са следећом командом:

$ судо кафка-конзола-потрошач.сх \
--зоокеепер лоцалхост: 2181 \
--корисници теме \
--отисак имовине.кеи = труе \
--кључ својства.сепаратор =, \
--од почетка

Као што видите, кључ и вредност пар који сам управо додао у корисника Тема је наведен.

Задржаћу Потрошач програм за корисника Тема отворите на овом терминалу и додајте остале кориснике у корисника Тема од другог Терминал и види шта ће се догодити.

Додајте другог корисника са тастер 2 са следећом командом:

$ ецхо "2, име: 'Јохн Дое', држава: 'БД'" | судо кафка-произвођач конзола.сх \
--брокер-лист лоцалхост: 9092 \
--корисници теме \
--рашчлањивање имовине.кеи = труе \
--кључ својства.сепаратор =,

Као што можете видети из означеног одељка снимка екрана испод, нови корисник је тренутно наведен у програму Потрошач.

Додајмо нашег последњег корисника са тастер 3 са следећом командом:

$ ецхо "3, наме: 'Евелина Акуилино', цоунтри: 'УС'" | судо кафка-произвођач конзола.сх \
--брокер-лист лоцалхост: 9092 \
--корисници теме \
--рашчлањивање имовине.кеи = труе \
--кључ својства.сепаратор =,

Као што видите, нови корисник је такође наведен у Потрошач програм.

Такође можете додати много корисника у исти Подела. Само се побрините за кључ је исти.

Хајде да додамо још једног корисника у Подела са тастер 1:

$ ецхо "1, наме: 'Линелле Пиатт', цоунтри: 'ЦА'" | судо кафка-произвођач конзола.сх \
--брокер-лист лоцалхост: 9092 \
--корисници теме \
--рашчлањивање имовине.кеи = труе \
--кључ својства.сепаратор =,

Као што видите, нови корисник је додат исправном Подела од корисници Тема.

Могу да наставим да додајем случајне кориснике у корисника Тема и они ће бити послати путем исправне партиције као што можете видети са снимка заслона испод.

Па тако Поделас у Апацхе Кафка ради. Свака Подела је попут а Ред чекања, прво се приказује прва порука коју пошаљете путем те партиције, а затим друга порука и тако редом којим су послати.

Ако си Јава програмер, можете да користите Јава програмски језик и АПИ Апацхе Кафка Јавас Апацхеом Кафком радити занимљиве ствари Поделас. На пример, можете доделити другачије Подела за различите собе за ћаскање за вашу апликацију за ћаскање, јер поруке морају бити приказане по редоследу слања.

Дакле, то је све за данас. Хвала вам што сте прочитали овај чланак.