So stellen Sie Kafka in Docker bereit
1. Docker erstellen Hier verwende ich direkt die Docker-Compose-Bereitstellung, daher müssen Sie Compose im Voraus installieren. Erstellen Sie zunächst ein neues Verzeichnis und erstellen Sie eine neue YML-Datei im Verzeichnis
Der Inhalt der Datei ist wie folgt:
Version: '2'
Leistungen:
Tierpfleger:
Bild: Wurstmeister/Zookeeper
Bände:
- ./Daten:/Daten
Häfen:
- „2181:2181“
Kafka:
Bild: Wurstmeister/Kafka
Häfen:
- „9092:9092“
Umfeld:
KAFKA_ADVERTISED_HOST_NAME:127.0.0.1
KAFKA_MESSAGE_MAX_BYTES: 2000000
KAFKA_CREATE_TOPICS: "Thema1:1:3,Thema2:1:1:kompakt"
KAFKA_ZOOKEEPER_CONNECT: Zookeeper:2181
Bände:
- ./kafka-logs:/kafka
– /var/run/docker.sock:/var/run/docker.sock
Kafka-Manager:
Bild: Sheepkiller/Kafka-Manager
Häfen:
9020:9000
Umfeld:
ZK_HOSTS: Tierpfleger:2181
Dann verwenden Sie diese YML-Datei, um unser Projekt zu starten $ docker-compose up -d Sie können sehen, dass drei neue Container erstellt wurden.
2. Betreten Sie den ContainerWir betreten den interaktiven Modus des Kafka-Containers mit dem folgenden Befehl $ docker exec -it kafkademo01_kafka_1 /bin/bash Da die höhere Version von Kafka über einen integrierten Zookeeper verfügt, müssen wir den Zookeeper-Container nicht aufrufen. Daher kann auf die Bereitstellung von Zookeeper in der YML-Datei verzichtet werden. Geben Sie dann das Stammverzeichnis von Kafka ein $ cd /opt/kafka 3. Ändern Sie die Konfigurationsdatei$ cd /konfiguration
Als erstes muss die Zookeeper-Konfigurationsdatei geändert werden: zookeeper.properties dataDir=/opt/kafka/zooLogs Client-Port = 2182 maxClientCnxns=0 admin.enableServer=false Ändern Sie dann die Kafka-Konfigurationsdatei: server.properties
#################################### Server-Grundlagen ################################
Broker-ID = 0
#################################### Socket-Server-Einstellungen #################################
Listener = PLAINTEXT://127.0.0.1:9093
#################################### Socket-Server-Einstellungen #################################
Listener = PLAINTEXT://127.0.0.1:9093
Anzahl.Netzwerkthreads=3
Anzahl.io.threads=8
socket.send.buffer.bytes=102400
socket.empfangen.puffer.bytes=102400
socket.request.max.bytes=104857600
###################################### Grundlagen des Protokolls ################################
log.dirs=/opt/kafka/kafkaLogs
Anzahl Partitionen = 1
Anzahl Wiederherstellungsthreads pro Datenverzeichnis = 1
################################### Interne Themeneinstellungen ##############################
Offsets.Thema.Replikationsfaktor=1
Transaktion.Status.Log.Replikation.Faktor=1
Transaktion.Status.log.min.isr=1
###################################### Richtlinie zur Protokollaufbewahrung ###############################
log.Aufbewahrungszeiten.Stunden=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
#################################### Tierpfleger ###############################
zookeeper.connect=127.0.0.1:2182
zookeeper.Verbindungstimeout.ms=18000
###################################### Einstellungen für Gruppenkoordinatoren #################################
Gruppe.initial.rebalance.delay.ms=0
Port=9093
beworbener.Host.Name=127.0.0.1
Nachricht.max.bytes=2000000
beworbener Port = 90934. Testen Sie KafkaHier sind einige grundlegende Befehle: ZooKeeper starten zookeeper-server-start.sh ../config/zookeeper.properties Starten Sie Kafka kafka-server-start.sh ../config/server.properties Ein Theme erstellen kafka-topics.sh --create --zookeeper 127.0.0.1:2182 --replication-factor 1 --partitions 1 --topic test Erstellte Themen anzeigen kafka-topics.sh --list --zookeeper 127.0.0.1:2182 Produzent kafka-console-producer.sh --broker-list 127.0.0.1:9093 --topic test Verbraucher kafka-console-consumer.sh --Bootstrap-Server 127.0.0.1:9093 - Thema Test --von-Beginn Dies ist das Ende dieses Artikels über die Schritte zum Bereitstellen von Kafka mit Docker. Weitere Informationen zum Bereitstellen von Kafka mit Docker finden Sie in früheren Artikeln auf 123WORDPRESS.COM oder in den folgenden verwandten Artikeln. Ich hoffe, Sie werden 123WORDPRESS.COM auch in Zukunft unterstützen! Das könnte Sie auch interessieren:
|
<<: Detaillierte Beschreibung des komponentenbasierten Front-End-Entwicklungsprozesses
>>: Tkinter verwendet JS-Canvas, um Farbverlaufsfarben zu erzielen
Artikel empfehlen
Installations-Tutorial zur komprimierten Version von MySQL 8.0.11 unter Win10
In diesem Artikel finden Sie das Installations-Tu...
Zusammenfassung der Benutzererfahrung
Unabhängig davon, ob Sie an Software oder Websites...
JavaScript zum Erreichen einer festen Seitenleiste
Verwenden Sie Javascript, um eine feste Seitenlei...
Detailliertes Tutorial zum Bereitstellen einer benutzerdefinierten Apollo-Umgebung mit Docker-Compose
Inhaltsverzeichnis Was ist das Apollo Configurati...
So implementieren Sie die King of Glory-Personal-Ladeseite mit CSS3
Wer King of Glory gespielt hat, sollte mit der Wi...
So lösen Sie das Problem, dass Tomcat9.exe abstürzt
Ein Leser kontaktierte mich und fragte, warum es ...
Detaillierte Erklärung der HTML-Tabellen-Tags (für Anfänger geeignet)
TABELLE> <TR> <TD> <TH> <...
Detaillierte Erklärung des Parsererror-Fehlerfalls in der JavaScript-Lösung in Ajax
Die ultimative Methode zur Lösung des Ajax-Parser...
HTML6 implementiert Beispielcode für Faltmenüs und Akkordeonmenüs
Der Hauptteil der Seite: <body> <ul id=&...
Designtheorie: Zehn Tipps zur Inhaltspräsentation
<br /> Der Entwurf einer persönlichen Schrei...
Installieren Sie Tomcat auf dem Linux-System und konfigurieren Sie den Start und das Herunterfahren des Dienstes
Konfigurieren des Startens und Herunterfahrens vo...
JavaScript zur Implementierung eines einfachen Karusselldiagramms, umfassendste Codeanalyse (ES5)
In diesem Artikel wird der spezifische Code für J...
MySQL-Daemon konnte nicht gestartet werden – Fehlerlösung
MySQL-Daemon konnte nicht gestartet werden – Fehl...
Detaillierte Erläuterung der Konstruktion der Lese-/Schreibtrennung bei der MySQL-Master-Slave-Replikation
MySQL Master-Slave-Einrichtung Die Einstellungen ...
Praxis der Verwendung von Tinymce Rich Text zum Anpassen von Symbolleistenschaltflächen in Vue
Inhaltsverzeichnis Installieren Sie die Deklarati...