Vitajte na [www.pocitac.win] Pripojiť k domovskej stránke Obľúbené stránky
Pred inštaláciou Apache Kafka sa uistite, že máte nasledujúce predpoklady:
- Server Ubuntu 18.04 s používateľom iného typu než root s oprávneniami `sudo`.
- Nainštalovaná súprava Java Development Kit (JDK) 8 alebo novšia.
- Zookeeper nainštalovaný a spustený. [Tu](/blog/how-to-install-zookeeper-on-ubuntu-1804) je návod, ako nainštalovať ZooKeeper na Ubuntu 18.04.
1. Navštívte oficiálnu stránku [Apache Kafka na stiahnutie](https://kafka.apache.org/download).
2. V časti „Vydania“ kliknite na najnovšie stabilné vydanie (napr. „2.8.0“).
3. Na stránke vydania kliknite na odkaz na stiahnutie súboru tarball (napr. `kafka_2.12-2.8.0.tgz`).
4. Na stiahnutie súboru tarball použite `wget`:
```
wget https://www-us.apache.org/dist/kafka/2.8.0/kafka_2.12-2.8.0.tgz
```
Po dokončení sťahovania rozbaľte súbor tarball do adresára podľa vášho výberu. V tomto príklade to rozbalíme do `/opt`:
```
sudo tar -xzvf kafka_2.12-2.8.0.tgz -C /opt
```
Tým sa vytvorí adresár s názvom `/opt/kafka_2.12-2.8.0`.
Na uľahčenie práce s Kafkom môžete nastaviť niektoré premenné prostredia. Pridajte nasledujúce riadky do svojho súboru `/etc/profile`:
```
exportovať KAFKA_HOME=/opt/kafka_2.12-2.8.0
export PATH=$KAFKA_HOME/bin:$PATH
```
Uložte súbor a zatvorte ho. Potom spustite nasledujúci príkaz na obnovenie premenných prostredia:
```
zdroj /etc/profile
```
Ak chcete spustiť Kafka, odporúča sa vytvoriť špeciálneho používateľa. To pomáha izolovať procesy Kafka od ostatných systémových procesov a zvyšuje bezpečnosť.
```
sudo adduser --system --group kafka
```
Kafka sa pri koordinácii spolieha na Zookeepera. Upravte súbor `config/zookeeper.properties` v inštalačnom adresári Kafka:
```
sudo vi /opt/kafka_2.12-2.8.0/config/zookeeper.properties
```
Uistite sa, že parameter `connect` ukazuje na súbor Zookeeper:
```
connect=localhost:2181
```
Uložte súbor a zatvorte ho.
Ďalej nakonfigurujme Kafku úpravou súboru `config/server.properties`:
```
sudo vi /opt/kafka_2.12-2.8.0/config/server.properties
```
Tu sú kľúčové nastavenia, ktoré je potrebné upraviť:
– Nahraďte reťazec „broker.id“ jedinečným ID tohto makléra (napr. „0“, ak ide o prvého makléra vo vašom klastri).
- Nastavte `zookeeper.connect` tak, aby ukazoval na súbor Zookeeper (napr. `localhost:2181`).
- Zvážte vyladenie parametra `log.dirs` na určenie adresára, do ktorého bude Kafka ukladať svoje záznamy.
- Skontrolujte ďalšie parametre, ako napríklad `num.partitions` a `default.replication.factor` na základe vašich požiadaviek.
Uložte súbor a zatvorte ho.
Témy sú základnými jednotkami ukladania údajov v Kafke. Ak chcete vytvoriť tému, spustite nasledujúci príkaz a nahraďte výraz „moja téma“ požadovaným názvom témy:
```
/opt/kafka_2.12-2.8.0/bin/kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1 --zookeeper localhost:2181
```
Ak chcete spustiť makléra Kafka, spustite nasledujúci príkaz:
```
/opt/kafka_2.12-2.8.0/bin/kafka-server-start.sh /opt/kafka_2.12-2.8.0/config/server.properties
```
Ak chcete otestovať, či Kafka funguje správne, môžete použiť nástroje `kafka-console-producer` a `kafka-console-consumer`.
Ak chcete vytvoriť správu, spustite nasledujúci príkaz a nahraďte „moja-téma“ názvom vašej témy:
```
/opt/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --topic my-topic --broker-list localhost:9092
```
V konzole napíšte správu a stlačte `Enter`.
Ak chcete správu použiť, spustite nasledujúci príkaz, pričom nahraďte `my-topic` názvom vašej témy:
```
/opt/kafka_2.12-2.8.0/bin/kafka-console-consumer.sh --topic my-topic --bootstrap-server localhost:9092 --from-beginning
```
V konzole by ste mali vidieť správu, ktorú ste vytvorili predtým.
Ak váš server Kafka nie je prístupný zvonka, možno budete musieť nakonfigurovať bránu firewall tak, aby umožňovala prichádzajúce pripojenia na porte 9092 (alebo ľubovoľnom vlastnom porte, ktorý ste zadali počas konfigurácie).
Úspešne ste nainštalovali a nakonfigurovali Apache Kafka na serveri Ubuntu 18.04. Teraz môžete preskúmať jeho možnosti a začať vytvárať aplikácie v reálnom čase.