#!/bin/bash
set -e

TOPIC_NAME="test-topic"
MESSAGE="Hello Kafka without Zookeeper!"

echo "🚀 Avvio Kafka in background..."
docker-compose up -d

echo "⏳ Attendo 10 secondi che Kafka sia pronto..."
sleep 10

echo "📌 Creo il topic '$TOPIC_NAME'..."
docker exec kafka kafka-topics.sh \
  --bootstrap-server localhost:9092 \
  --create --topic "$TOPIC_NAME" \
  --partitions 1 --replication-factor 1

echo "📋 Lista dei topic disponibili:"
docker exec kafka kafka-topics.sh \
  --bootstrap-server localhost:9092 --list

echo "✉️ Invio un messaggio al topic..."
echo "$MESSAGE" | docker exec -i kafka kafka-console-producer.sh \
  --broker-list localhost:9092 --topic "$TOPIC_NAME"

echo "📥 Lettura del messaggio dal topic:"
docker exec kafka kafka-console-consumer.sh \
  --bootstrap-server localhost:9092 \
  --topic "$TOPIC_NAME" --from-beginning --timeout-ms 5000

echo "✅ Test completato!"