Ubuntu et Kafka

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