Acest articol este un articol oglindă al traducerii automate, vă rugăm să faceți clic aici pentru a sări la articolul original.

Architect_Programmer_Code Rețeaua Agricolă»Arhitect › Programare › Chat tehnic › CentOS construiește middleware de mesaje Kafka
Vedere: 5413|Răspunde: 2

CentOS construiește middleware de mesaje Kafka

[Copiază linkul]
Postat pe 12.12.2021 12:25:22 | | | |
Kafka este o platformă de streaming open-source dezvoltată de Apache Software Foundation, scrisă în Scala și Java. Kafka este un sistem distribuit de mesagerie publicare-abonare cu debit ridicat care procesează toate datele despre fluxul de acțiuni ale consumatorului pe site. Această acțiune (navigarea pe web, căutarea și alte acțiuni ale utilizatorilor) este un factor cheie în multe funcții sociale de pe web-ul modern. Aceste date sunt adesea rezolvate prin procesarea jurnalelor și agregarea jurnalelor datorită cerințelor de throughput. Aceasta este o soluție viabilă pentru date de jurnal și sisteme de analiză offline precum Hadoop, dar necesită limitările procesării în timp real. Scopul Kafka este de a unifica procesarea mesajelor online și offline prin mecanismul de încărcare paralelă al Hadoop și, de asemenea, de a oferi mesaje în timp real prin clusterizare.

Recenzie:

Operații Kafka pentru cozi de mesaje .NET/C# [cu cod sursă]
https://www.itsvse.com/thread-9619-1-1.html

Kafka configurează monitorizarea la distanță JMX
https://www.itsvse.com/thread-9968-1-1.html

În primul rând, folosesc un sistem CentOS 8 cu versiunea Kafka:kafka_2.13-3.0.0。

Descarcă comanda unzip astfel:

Configurează Kafka

Mergi la folderul /data/middleware/kafka_2.13-3.0.0/config și modifică-lserver.proprietățiPrincipalele amendamente sunt următoarele:

Lansarea Zookeeper și Kafka

Comanda Start

Comandă de oprire

Înregistrează Zookeeper și Kafka ca serviciu

Mergi la folderul /etc/systemd/system

Creează un nou fișier de serviciu zookeeper.service cu următoarea configurație:
Începe și configurează startup-ul

Creează un nou fișier de serviciu kafka.service și configurează-l astfel:



Începe și configurează startup-ul


Verificați starea serviciilor Zookeeper și Kafka, așa cum este prezentat în imaginea următoare:



Portarea implicită Kafka:9092, port implicit Zookeeper:2181în acest proces19988 Este un port JMX!




Precedent:Tutorial de implementare a sistemului CentOS pentru nacos
Următor:【Combat practic】Ajustarea parametrilor Kafka rezolvă problema corpului prea mare al mesajului

Postări conexe
 Proprietarul| Postat pe 24.12.2021 11:25:13 |
Configurația JMX, iar mediul Linux poate modifica direct fișierul kafka-server-start.sh, după cum urmează:

Postat pe 26.12.2021 16:58:13 |
Învață să înveți。。。。。。
Disclaimer:
Tot software-ul, materialele de programare sau articolele publicate de Code Farmer Network sunt destinate exclusiv scopurilor de învățare și cercetare; Conținutul de mai sus nu va fi folosit în scopuri comerciale sau ilegale, altfel utilizatorii vor suporta toate consecințele. Informațiile de pe acest site provin de pe Internet, iar disputele privind drepturile de autor nu au legătură cu acest site. Trebuie să ștergi complet conținutul de mai sus de pe calculatorul tău în termen de 24 de ore de la descărcare. Dacă îți place programul, te rugăm să susții software-ul autentic, să cumperi înregistrarea și să primești servicii autentice mai bune. Dacă există vreo încălcare, vă rugăm să ne contactați prin e-mail.
Mail To:help@itsvse.com