Kuinka asentaa Kafka?
Kafka on hajautettu suoratoistoalusta. Se auttaa tietuevirtojen julkaisemisessa ja tilaamisessa. Kafkaa käytetään yleensä reaaliaikaisten suoratoistoputkien rakentamiseen, jotka saavat luotettavasti tietoja eri järjestelmien ja sovellusten välillä. Se voi myös auttaa rakentamaan reaaliaikaisia suoratoistosovelluksia, jotka auttavat muuntamaan tai muuttamaan tietovirtoja. Kafka mahdollistaa tallennusvirtojen tallentamisen eri kategorioihin, joita kutsutaan aiheiksi. Jokainen tietue koostuu avaimesta, arvosta ja aikaleimasta. Sillä on neljä pääkomponenttia, kuten Producer API, Consumer API, Streams API ja Connector API. Se käyttää TCP-protokollaa, joka on hyvä viestintä korkean suorituskyvyn asiakkaiden ja palvelimien välillä. Kafkan asentamiseksi voidaan noudattaa seuraavia vaiheita.
Asenna Kafka Windows-käyttöjärjestelmään
Asenna Kafka Windows: iin seuraavasti:
Vaihe 1. Lataa Zookeeper seuraavasta linkistä: HTTP: //zookeeper.apache.org/releases.html
Kun tämä on tehty, lataa Kafka seuraavasta linkistä: http://kafka.apache.org/downloads.html
Lataa myös JRE käyttöjärjestelmäsi ja CPU-arkkitehtuurisi mukaisesti alla olevasta linkistä: http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html
Vaihe 2. JDK-asennus-
Käynnistä JRE-asennus ja napsauta sitten Vaihda kohdekansio -valintaruutua. Napsauta nyt asentaa.
Kun tämä on tehty, vaihda hakemisto mihin tahansa polkuun ilman välilyöntejä kansion nimessä.
Vaihe 3. Kun tämä on tehty, avaa ympäristömuuttujat Ohjauspaneeli -> Järjestelmä -> Lisäasetukset järjestelmästä -> Ympäristömuuttujat.
Vaihe 4. Napsauta Uusi käyttäjämuuttuja Käyttäjämuuttuja-välilehdellä ja kirjoita sitten JAVA_HOME muuttujan nimeen. Kirjoita JRE-polku Muuttuva arvo -osaan. Sen pitäisi olla seuraava:
Vaihe 5. Napsauta nyt OK.
Vaihe 6. Etsi polkumuuttuja avautuvasta ”Ympäristömuuttuja” -valintaikkunan ”Järjestelmämuuttuja” -osiosta.
Vaihe 7. Muokkaa polkua ja kirjoita ";% JAVA_HOME% \ bin" jo kirjoitetun tekstin loppuun, aivan kuten alla oleva kuva:
Vaihe 8. Jos haluat tarkistaa, onko Java asennettu oikein, siirry komentokehotteeseen ja kirjoita 'java - versio'. Asennettu Java-versio näkyy näytöllä.
Jos näet yllä olevat yksityiskohdat komentokehotteessa, olet Java-puolelta hyvä.
Kun Java on asennettu, voit nyt siirtyä saadaksesi Zookeeperin asennuksen valmiiksi.
Seuraa alla olevia vaiheita saadaksesi Zookeeper asennettuna järjestelmään:
- Avaa hakemisto, jossa Zookeeper-konfiguraatiohakemisto on. Se voi olla C: \ zookeeper-3.4.7 \ conf.
- Nyt nimeä tiedosto “zoo_sample.cfg” nimeksi “cfg”
- Avaa tämä nimetty tiedosto Muistiossa.
- Etsi ja muokkaa seuraavaa: dataDir = / tmp / zookeeper - \ zookeeper-3.4.7 \ data
- Aivan kuten lisäsimme Java-ympäristömuuttujan, lisäämme ympäristömuuttujan Zookeeperille.
- Aseta järjestelmämuuttujan polkuksi: dataDir = / tmp / zookeeper arvoon: \ zookeeper-3.4.7 \ data
- Muokkaa järjestelmämuuttujaa nimeltä 'Path' ja lisää; % ZOOKEEPER_HOME% \ bin;
- Zookeeperin oletusportti on 2181, joka voidaan muuttaa mihin tahansa muuhun porttiin siirtymällä zoo.cfg-tiedostoon.
- Suorita Zookeeper avaamalla uusi cmd ja kirjoittamalla 'zkserver'. Näet alla olevat yksityiskohdat.
Kun näet tämän näytön, sinun tulee olla varma, että Zookeeper on asennettu onnistuneesti.
Kafkan perustaminen
Kun Java ja Zookeeper ovat käynnissä ja käynnissä järjestelmässä, voit edetä määrittämään Kafkan.
- Siirry Kafkan konfigurointihakemistoon.
- Muokkaa tiedostoa “server.properties”.
- Kun tämä on tehty, voit löytää ja muokata näkemääsi riviä: dirs = / tmp / kafka-lokit muotoon “log.dir = C: \ kafka_2.11-0.9.0.0 \ kafka-lokit
- Jos sinulla on eläintarhasi pitäjä käynnissä jollakin toisella koneella, voit muuttaa tämän polun nimellä “zookeeper.connect: 2181” mukautettuun IP- ja porttitunnukseen.
- Kafkan oletusportti on portti 9092, ja yhteys Zookeeperiin on 2181.
Kafka-palvelimen suorittaminen
Kun alkuperäinen asennus on valmis, voit suorittaa Kafka-palvelimen helposti
Ennen Kafka-palvelimen suorittamista on varmistettava, että Zookeeper-ilmentymä on käynnissä.
1. Siirry Kafkan asennushakemistoon: C: /kafka_2.11-0.9.0.0
2. Avaa komentokehote ja paina Vaihto + hiiren oikealla painikkeella ja valitse 'Avaa komentoikkuna täällä' -vaihtoehto.
3. Kirjoita nyt. \ Bin \ Windows \ kafka-server-start.bat. \ Config \ server.properties ja paina Enter.
Kun olet suorittanut tämän ja kaikki on kunnossa, näytön tulisi näyttää seuraavalta:
4. Nyt Kafka-palvelimesi on valmis. Voit luoda omia aiheita eri viestien tallentamiseksi. Kun tämä on tehty, voit tuottaa ja kuluttaa tietoja Java- tai Scala-koodista tai suorittaa suoraan komentoriviltä.
Asenna Kafka Linuxiin
Asenna Kafka Linuxiin seuraavien ohjeiden mukaan:
Vaihe 1. Lataa ja purkaa Kafka-binaareja ja tallenna ne hakemistoihin.
Vaihe 2. Pura lataamasi arkisto tar-komennolla.
Vaihe 3. Jos haluat määrittää Kafkan, siirry osoitteeseen server.properties. Avaa tämä tiedosto nano-komennolla ja lisää seuraavat tiedoston alaosaan.
nano ~/Kafka/config/server.properties
delete.topic.enable = true
Vaihe 4. Kun tämä on tehty, käyttäjän on luotava järjestelmäyksikötiedostot Kafka-palveluille. Tämä auttaa suorittamaan yleisiä palvelutoimintoja, kuten Kafkan käynnistäminen, pysäyttäminen ja uudelleenkäynnistäminen yhdenmukaisesti muiden Linux-palveluiden kanssa. Eläintarhanhoitaja on palvelu, jota Kafka käyttää hallitsemaan klusteriaan ja kokoonpanojaan.
Vaihe 5. Yksilöllisen tiedoston luominen Zookeeperille seuraa seuraavasti:
sudo nano /etc/systemd/system/zookeeper.service
Vaihe 6. Kun tämä zookeeper-tiedosto on luotu, liitä sen alla oleva teksti:
(Unit) Requires=network.target remote-fs.target
After=network.target remotefs.target
(Service) Type=simple
User=kafka
ExecStart=/home/kafka/kafka/bin/zookeeper-server-start.sh /home/kafka/kafka/config/zookeeper.properties
ExecStop=/home/kafka/kafka/bin/zookeeper-server-stop.sh
Restart=on-abnormal
(Install) WantedBy=multi-user.target
Tässä (yksikkö) -osiossa määritetään, että Zookeeper vaatii verkottumisen ja tiedostojärjestelmän olevan valmis ennen kuin se voi käynnistyä.
(Palvelu) -osa antaa järjestelmälle tietää, että zookeeper-server-start.sh- ja zookeeper-server-stop.sh-tiedostot ovat läsnä palveluiden käynnistämiseen ja lopettamiseen.
Vaihe 7. Nyt käyttäjän on luotava Kafka-järjestelmätiedosto alla esitetyllä tavalla:sudo nano /etc/system/system/Kafka.service
Vaihe 8. Tämän tiedoston liitä alla:
(Unit) Requires=zookeeper.service
After=zookeeper.service
(Service) Type=simple
User=kafka
ExecStart=/bin/sh -c '/home/kafka/kafka/bin/kafka-server-start.sh
/home/kafka/kafka/config/server.properties >
/home/kafka/kafka/kafka.log 2>&1'
ExecStop=/home/kafka/kafka/bin/kafka-server-stop.shRestart=on-abnormal
(Install) WantedBy=multi-user.target
Tässä (Yksikkö) määrittelee, että yksikötiedosto on riippuvainen zookeeper.service-palvelusta. Tämä varmistaa, että eläintarhanhoitaja aloitetaan ennen Kafkan aloittamista.
Vaihe 9. Sinun täytyy nyt ottaa Kafka käyttöön ja käynnistää palvelin uudelleen. Suorita: sudo systemctl mahdollistaa Kafkan
Vaihe 10. Asennuksen testaaminen:
Voit testata Kafka-asennuksen luomalla aiheen ja julkaisemalla sen sitten kuluttajille.
Luo aihe : ~ / Kafka / bin / Kafka-topics.sh - luominen - eläintarhanhoitajan paikallismäärä: 2181 - korjauskerroin 1 - osiot 1 - aiheoppiTopic
Lähetä tämä käyttäjä voi luoda tuottajia ja kuluttajia ja sitten julkaista kaiken tietyn aiheen tiedot.
Suositellut artikkelit
Tämä on opas Kafkan asentamiseen. Täällä olemme keskustelleet eri vaiheista Kafkan asentamiseksi Windows ja Linux. Voit myös katsoa seuraavia artikkeleita saadaksesi lisätietoja -
- Vaihe Java 8: n asentamiseen
- Kuinka asentaa C
- Opas Rubyn asentamiseen
- Kafka-sovellukset
- JRE vs. JVM | 8 parasta eroa (infografia) kanssa