Commandes à exécuter
À noter, j'ai utilisé avec la version kafka_2.13-3.1.0 et Ubuntu 20.04.
Pré-requis, une version de JAVA moderne:
sudo apt install openjdk-17-jre-headless
Pour partir un serveur à partir de Debian où Kafka n'est pas installé:
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz.KEYS
wget https://downloads.apache.org/kafka/KEYS
gpg --import KEYS
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz.asc
gpg --keyserver pgpkeys.mit.edu --recv-key DE885DD3
gpg --verify kafka_2.13-3.1.0.tgz.asc kafka_2.13-3.1.0.tgz
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz.sha512
gpg --print-md SHA512 kafka_2.13-3.1.0.tgz | cmp kafka_2.13-3.1.0.tgz.sha512
tar -xzf kafka_2.13-3.1.0.tgz
cd kafka_2.13-3.1.0/
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 \
--replication-factor 1 --partitions 1 --topic streams-plaintext-input
Pour partir un client:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 \
--partitions 1 --topic streams-wordcount-output --config cleanup.policy=compact
Références
https://kafka.apache.org/31/documentation/streams/quickstart
https://www.apache.org/dyn/closer.cgi?path=/kafka/3.1.0/kafka_2.13-3.1.0.tgz
https://dist.apache.org/repos/dist/release/kafka/KEYS
https://www.apache.org/info/verification.html