7,540
edits
Changes
→Környezet kialakítása
A zookeeper és a Kafka broker a kafka-net overlay hálózaton keresztül fognak kommunikálni. Azonban mind a Kafka-t mind a zookeper-t ki kell ajánlani az ingress hálózaton keresztül a külvilágnak, hogy a külső termelők és fogyasztók elérjék őket. A termelők és fogyasztók bármelyik swarm node-on keresztül elérik a Kafa-t ill a zookeeper-t, erről az ingress hálózat gondoskodik.
==Swarm stack létrehozása==
A swarm stack-et az alábbi swarm yaml fájllal fogjuk létrehozni. Ebben definiálunk egy zookeeper service-t és egy kafka broker service-t külső volume felcsatolása nélkül, tehát minden konfigurációt környezeti változóként adunk meg. Mind a zookeeper mind a kafka image-nek az apache-os image helyett a confluent image-t fogjuk használni. A confluent továbbfejlesztett Kafka termékcsaládot árul, ami stabilabb és jóval több funkciót tartalmaz mint az eredeti Kafka (https://www.confluent.io)
:[[File:ClipCapIt-190420-223641.PNG]]
confluent_swarm.yaml
<source lang="C++">
version: '3.2'
* KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 -> ...
Hozzuk létre a docker stack-et:
<pre>
# docker stack deploy -c confluent_swarm.yaml confluence
</pre>
Listázzuk ki a stack-ban létrejött service-eket és az overlay hálózatot:
<pre>
# docker service ls
ID NAME MODE REPLICAS IMAGE PORTS
7vjvop7tqiyc confluent_kafka replicated 1/1 confluentinc/cp-kafka:5.1.2 *:29092->29092/tcp
oxxjtkcusj1f confluent_zookeeper replicated 1/1 confluentinc/cp-zookeeper:5.1.2 *:32181->32181/tcp
</pre>
És listázzuk ki az összes swarm hálózatot. Láthatjuk hogy létrejött a kfaka-net nevű overlay hálózat.
<pre>
# docker network ls
NETWORK ID NAME DRIVER SCOPE
...
5albky0eu1to confluent_kafka-net overlay swarm
olqkh5zlqiac ingress overlay swarm
...
</pre>
<br>
==Topic-ok kezelése==