Installer Apache Kafka på Ubuntu
Installere Apache Kafka
Oppdater først pakkelagdebufferen til Ubuntu -serveren din med følgende kommando:
$ sudo apt-get oppdatering
Pakkelagerbufferen skal oppdateres.
Apache Kafka avhenger av Java. Du kan installere OpenJDK 8 på Ubuntu 17.10 fra det offisielle pakkelageret.
Kjør følgende kommando for å installere OpenJDK 8 på Ubuntu 17.10:
$ sudo apt-get install openjdk-8-jdk
Trykk nå 'Y' og trykk deretter for å fortsette.
OpenJDK 8 skal installeres.
Nå må du installere dyrepasser. Det er tilgjengelig i det offisielle pakkelagde av Ubuntu.
Å installere dyrepasser, Kjør følgende kommando:
$ sudo apt-get install zookeeperd
Trykk nå 'Y' og trykk deretter for å fortsette.
dyrepasser skal installeres.
Du kan kjøre følgende kommando for å sjekke om dyrepasser løper:
$ sudo systemctl status zookeeper
Som du kan se fra skjermbildet nedenfor, dyrepasser løper.
Hvis den ikke kjører på maskinen din av en eller annen grunn, kan du starte dyrepasser med følgende kommando:
$ sudo systemctl start zookeeper
Du bør legge til dyrepasser til systemstarten. Så det starter automatisk på oppstart.
Kjør følgende kommando for å legge til dyrepasser til systemstarten:
$ sudo SystemCTL Enable ZooKeeper
dyrepasser bør legges til systemoppstarten som du kan se fra skjermdumpen nedenfor.
jeg trenger Netstat Kommando som er gitt av Nettobehandling pakke.
Nå installer Nettobehandling Pakke med følgende kommando:
$ sudo apt-get install net-tools
Nettobehandling Pakken skal installeres.
Nå kan du kjøre følgende kommando for å sjekke om Zookeeper kjører på port 2181.
$ sudo netstat -tulpen | Grep 2181
Som du ser kjører den på port 2181.
Kjør nå følgende kommando for å navigere til ~/ nedlastinger/ katalogen i brukerne Home Directory:
$ cd ~/nedlastinger
Nå må du laste ned Apache Kafka. I skrivende stund er den siste versjonen av Apache Kafka V1.0.0.
Kjør følgende kommando for å laste ned Apache Kafka 1.0.0 med WGET:
$ wget http: // www-eu.Apache.org/dist/kafka/1.0.0/Kafka_2.12-1.0.0.tgz
Apache Kafka komprimert arkiv bør lastes ned.
Som du ser fra utgangen fra LS -kommandoen, er filnavnet til Apache Kafka Archive Kafka_2.12-1.0.0.tgz
Lag nå en katalog Kafka/ i /opt Katalog med følgende kommando:
$ sudo mkdir /opt /kafka
En katalog /opt/kafka bør opprettes. Det er her jeg vil trekke ut arkivet.
Pakk ut Apache Kafka -arkivet i /opt/kafka Katalog med følgende kommando:
$ sudo tar xvzf kafka_2.12-1.0.0.tgz -c /opt /kafka
Arkivet skal trekkes ut.
Du kan kjøre følgende kommando for å sjekke katalognavnet:
$ ls /opt /kafka
Merk at katalognavnet.
Nå åpen /etc/profil med følgende kommando:
$ sudo nano /etc /profil
Legg til følgende linjer til slutten av filen og lagre den.
Nå åpner ~/.Bashrc fil med følgende kommando:
$ sudo nano ~/.Bashrc
Legg til den markerte linjen til slutten av filen som lagre den.
Start datamaskinen på nytt med følgende kommando:
$ sudo omstart
Når datamaskinen starter, kan du sjekke om miljøvariablene er lagt til som følger:
$ ekko $ kafka_home
$ ekko $ bane
Nå for å gjøre livet vårt enklere, lag en symbolsk kobling av Kafka server.egenskaper fil som følger:
$ sudo ln -s $ kafka_home/config/server.Egenskaper /etc /kafka.egenskaper
Som du ser fra skjermbildet nedenfor, opprettes den symbolske lenken.
Nå kan du starte Apache Kafka Server med følgende kommando:
$ sudo kafka-server-start.sh /etc /kafka.egenskaper
Apache Kafka Server bør startes.
Testing Apache Kafka Server
Du kan opprette et testemne testing På Apache Kafka -server med følgende kommando:
$ sudo kafka-emner.SH-Create-Zookeeper LocalHost: 2181-Replication-Factor 1
--Partisjoner 1 -tema testing
EN testing Emnet skal opprettes som vist på skjermdumpen nedenfor.
Kjør nå følgende kommando for å bruke Kafka -produsent API for å sende litt melding til testing emne:
$ sudo kafka-console-produsent.SH-BROKER-LIST LocalHost: 9092-tema testing
Når du har trykket på, bør du se et nytt pil (>) -skilt som vist på skjermdumpen nedenfor.
Bare skriv inn noe og trykk for å starte en ny linje. Jeg skrev inn 3 linjer med tekster.
Nå kan du bruke Kafka Consumer API for å hente meldingene/linjene fra testing Emne med følgende kommando:
$ Sudo Kafka-Console-Consumer.SH --zookeeper Localhost: 2181 --
Emnetesting-fra-Beginning
Du skal kunne se meldingene eller linjene du har skrevet ved hjelp av produsent API som merket på skjermbildet nedenfor.
Hvis du skriver en ny melding ved hjelp av produsent API, bør den også vises øyeblikkelig på forbrukersiden som vist på skjermbildet nedenfor.
Så det er slik du installerer Apache Kafka og bekreft at det fungerer på Ubuntu 17.10 Artful Aardvark. Takk for at du leste denne artikkelen.