Ei bine, e timpul pentru a trimite date peste orice Kafka Apache. Dar, în primul rând, desigur, trebuie să instalați.
Instalarea lui Kafka este atât de simplu, ca de data aceasta am abate de la regulile sale obișnuite și, de fapt, va explica modul în care să-l instalați. Astfel, cei patru pași simpli:
- Instalați Java Development Kit (pentru un motiv oarecare, de multe ori este deja instalat)
- Descărcați o copie a lui Kafka
- Despacheta (gudron - xzf kafka_2 11 -. 0.10.1.0.tgz în sistemele * nix)
- Totul. Kafka gata.
Sincer, e chiar totul. Dar, înainte de a merge mai departe, este în valoare de o privire în jur:
Uită-te în interiorul folderul kafka
Complet cu Kafka merge bine o mulțime de dosare, și avem nevoie doar două dintre ele: bin. care deține scripturi shell și configurare. în cazul în care fișierele de configurare sunt servicii ascunse.
Cum de a rula Kafka
Așa cum am menționat ultima dată. chiar broker singuratic kafkiană - un cluster, astfel încât lansarea sa este un pic diferit de rulare a aceluiași RabbitMQ. Spre deosebire de iepure, Kafka au nevoie de un serviciu de ajutor pentru a coordona activitatea brokerilor grădina zoologică din cluster, iar numele acestui serviciu - Zookeeper. Atunci când un nou subiect, sau pentru a adăuga un nou broker sau elimina vechi, Zookeeper - este cel care se va ocupa de toate astea. El va decide unde să pună un nou subiect, descărcați un nou broker, și chiar și modul în care să echilibreze un set de replici, în cazul în care unii dintre ei au mers împreună la serviciul căzut. El este supraveghetorul și coordonator, și primul său început.
Cum de a rula Apache Zookeeper
instalare Kafka vine complet cu Zookeeper, astfel încât căutarea este de peste înainte de a fi început. Script-ul pentru a rula este în folderul bin, și configurația - în configurare. și, de fapt, este nevoie de nimic mai mult:
Pornirea Apache Zookeeper
Acum, că serverul se execută, este timpul să-l trimită ceva.
Trimiterea și primirea mesajelor
Pentru a trimite sau primi ceva, aveți nevoie de mai multe trei etape (mici): a crea un subiect care va stoca mesajul, a crea un producător care a fost ceea ce a păstra și de consum, de aceea. Și există un script de shell pentru toate acestea.
crea un subiect
Crează un subiect Kafka
Ca producător, beneficiarul trebuie să specifice cel puțin un anumit punct de intrare la cluster-ul prin intermediul parametrului - - bootstrap - server. El deține, de asemenea, o sesiune deschisă și afișează terminalul tot ce este în măsură să obțină de la Kafka.
Și totuși! Într-un fel, în mod inexplicabil, fără o singură linie de cod, avem un cluster care rulează cu o singură gazdă, prin care a trecut un cuplu de mesaje.
concluzie
Serverul Kafka-run și să treacă printr-un mesaj, în general, este mai complicat decât face același lucru cu RabbitMQ și mai ales cu ZeroMQ (practic, totul în această lume este mai complicată decât ZeroMQ). Pe de altă parte, pentru a trece de la un grup de gazdă a cluster cu distribuite mnogohostovomu Topeka, este necesar un efort suplimentar. Aceasta este ceea ce vom verifica data viitoare.