33 lines
910 B
Bash
33 lines
910 B
Bash
#!/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!"
|