Bonjour
j'essaie de tester Kafka via Docker.
j'ai le docker-compose suivant :
Code : Sélectionner tout - Visualiser dans une fenêtre à part
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
version: "3.2"
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181"

  kafka:
    image: wurstmeister/kafka
    depends_on:
      - zookeeper
    ports:
      - "9092-9094:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 0.0.0.0
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

  kafkaui:
    image: provectuslabs/kafka-ui
    depends_on:
      - kafka
      - zookeeper
    ports:
      - "8080:8080"
    environment:
      KAFKA_CLUSTERS_0_NAME: local
      KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: "kafka:9092"
pour le champs KAFKA_ADVERTISED_HOST_NAME, je met mon ip local : 0.0.0.0

quand je fais docker-compose up -d tout est OK
puis je fais
Code : Sélectionner tout - Visualiser dans une fenêtre à part
docker-compose up --scale kafka=3 -d
pour avoir 3 noeuds.
je vérifier avec docker ps -a, j'ai bien tous les contenairs qui sont en UP.

Sur mon navigateur, je vais à l'url 0.0.0.0:8080 et j'ai bien accès à l'interface graphique.

je vois le cluster online, mais je n'arrive pas à accéder au menu "broker". C'est bizarre non?

Puis j'essaie de faire un test avec ce fichier python où j'écris des topics:
Code : Sélectionner tout - Visualiser dans une fenêtre à part
1
2
3
4
5
6
7
8
9
from kafka import KafkaProducer


kafka_producer = KafkaProducer(bootstrap_servers="localhost:9092")

for i in range(1, 4):
    kafka_producer.send(topic="test", value=f"New message # {i}".encode("utf-8"))

kafka_producer.flush()
et là j'ai un timeout error, puis sur l'interface graphique, je vois que le cluster est offline alors que les containers sont toujours up quand je fais docker ps -a

j'ai un vieux pc avec un intel Intel Core i3-3120M et 3.7GiB de ram
est-ce suffisant pour faire tourner kafka?