Zorg ervoor dat u aan de volgende vereisten voldoet voordat u Apache Kafka installeert:

- Ubuntu 18.04-server met een niet-rootgebruiker met `sudo`-rechten.

- Java Development Kit (JDK) 8 of hoger geïnstalleerd.

- Zookeeper geïnstalleerd en actief. [Hier](/blog/how-to-install-zookeeper-on-ubuntu-1804) leest u hoe u ZooKeeper op Ubuntu 18.04 installeert.

Stap 2:Apache Kafka downloaden

1. Bezoek de officiële [Apache Kafka download](https://kafka.apache.org/download) pagina.

2. Klik onder het gedeelte "Releases" op de nieuwste stabiele release (bijvoorbeeld `2.8.0`).

3. Klik op de releasepagina op de link om het tarball-bestand te downloaden (bijvoorbeeld `kafka_2.12-2.8.0.tgz`).

4. Gebruik `wget` om het tarball-bestand te downloaden:

```

wget https://www-us.apache.org/dist/kafka/2.8.0/kafka_2.12-2.8.0.tgz

```

Stap 3:Pak de tarball uit

Zodra het downloaden is voltooid, pakt u het tarball-bestand uit naar een map naar keuze. In dit voorbeeld extraheren we het naar `/opt`:

```

sudo tar -xzvf kafka_2.12-2.8.0.tgz -C /opt

```

Hierdoor wordt een map aangemaakt met de naam `/opt/kafka_2.12-2.8.0`.

Stap 4:Stel omgevingsvariabelen in

Om het werken met Kafka gemakkelijker te maken, kunt u enkele omgevingsvariabelen instellen. Voeg de volgende regels toe aan uw `/etc/profile`-bestand:

```

exporteer KAFKA_HOME=/opt/kafka_2.12-2.8.0

export PATH=$KAFKA_HOME/bin:$PATH

```

Sla het bestand op en sluit het. Voer vervolgens de volgende opdracht uit om de omgevingsvariabelen te vernieuwen:

```

bron /etc/profile

```

Stap 5:Kafka-gebruiker maken

Om Kafka uit te voeren, is het raadzaam een ​​speciale gebruiker aan te maken. Dit helpt Kafka-processen te isoleren van andere systeemprocessen en verbetert de beveiliging.

```

sudo adduser --system --group kafka

```

Stap 6:Zookeeper configureren

Kafka vertrouwt op Zookeeper voor de coördinatie. Bewerk het bestand `config/zookeeper.properties` in de installatiemap van Kafka:

```

sudo vi /opt/kafka_2.12-2.8.0/config/zookeeper.properties

```

Zorg ervoor dat de parameter `connect` verwijst naar het Zookeeper-ensemble:

```

connect=lokalehost:2181

```

Sla het bestand op en sluit het.

Stap 7:Kafka configureren

Laten we vervolgens Kafka configureren door het bestand `config/server.properties` te bewerken:

```

sudo vi /opt/kafka_2.12-2.8.0/config/server.properties

```

Dit zijn de belangrijkste instellingen die u moet wijzigen:

- Vervang `broker.id` door een unieke ID voor deze makelaar (bijvoorbeeld `0` als dit de eerste makelaar in uw cluster is).

- Stel `zookeeper.connect` in om naar het Zookeeper-ensemble te verwijzen (bijvoorbeeld `localhost:2181`).

- Overweeg de parameter `log.dirs` af te stemmen om de map te specificeren waar Kafka zijn logs zal opslaan.

- Controleer andere parameters zoals `num.partitions` en `default.replication.factor` op basis van uw vereisten.

Sla het bestand op en sluit het.

Stap 8:Onderwerpen maken

Onderwerpen zijn de fundamentele eenheden van gegevensopslag in Kafka. Om een ​​onderwerp aan te maken, voert u de volgende opdracht uit, waarbij u `mijn-onderwerp` vervangt door de gewenste onderwerpnaam:

```

/opt/kafka_2.12-2.8.0/bin/kafka-topics.sh --create --topic mijn-onderwerp --partities 1 --replicatiefactor 1 --zookeeper localhost:2181

```

Stap 9:Start Kafka

Voer de volgende opdracht uit om de Kafka-makelaar te starten:

```

/opt/kafka_2.12-2.8.0/bin/kafka-server-start.sh /opt/kafka_2.12-2.8.0/config/server.properties

```

Stap 10:Test Kafka

Om te testen of Kafka goed werkt, kunt u de tools `kafka-console-producer` en `kafka-console-consumer` gebruiken.

Maak een bericht

Om een ​​bericht te produceren, voert u de volgende opdracht uit, waarbij u `mijn-onderwerp` vervangt door uw onderwerpnaam:

```

/opt/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --topic mijn-onderwerp --broker-lijst localhost:9092

```

Typ een bericht in de console en druk op 'Enter'.

Gebruik een bericht

Om het bericht te verwerken, voert u de volgende opdracht uit, waarbij u `mijn-onderwerp` vervangt door uw onderwerpnaam:

```

/opt/kafka_2.12-2.8.0/bin/kafka-console-consumer.sh --topic mijn-onderwerp --bootstrap-server localhost:9092 --from-beginning

```

In de console zou je het bericht moeten zien dat je eerder hebt geproduceerd.

Stap 11:Firewall configureren (optioneel)

Als uw Kafka-server niet extern toegankelijk is, moet u mogelijk uw firewall configureren om inkomende verbindingen op poort 9092 (of een aangepaste poort die u tijdens de configuratie hebt opgegeven) toe te staan.

Conclusie

U hebt Apache Kafka met succes geïnstalleerd en geconfigureerd op uw Ubuntu 18.04-server. Nu kunt u de mogelijkheden ervan verkennen en beginnen met het bouwen van realtime applicaties.