@echo off
REM Script pour créer les topics Kafka pour UnionFlow
REM Exécuter depuis le répertoire unionflow/

echo ====================================
echo Création des topics Kafka UnionFlow
echo ====================================
echo.

echo Topic 1/5: unionflow.finance.approvals
docker exec kafka /opt/kafka/bin/kafka-topics.sh --create --topic unionflow.finance.approvals --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1 --if-not-exists

echo Topic 2/5: unionflow.dashboard.stats
docker exec kafka /opt/kafka/bin/kafka-topics.sh --create --topic unionflow.dashboard.stats --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1 --if-not-exists

echo Topic 3/5: unionflow.notifications.user
docker exec kafka /opt/kafka/bin/kafka-topics.sh --create --topic unionflow.notifications.user --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1 --if-not-exists

echo Topic 4/5: unionflow.members.events
docker exec kafka /opt/kafka/bin/kafka-topics.sh --create --topic unionflow.members.events --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1 --if-not-exists

echo Topic 5/5: unionflow.contributions.events
docker exec kafka /opt/kafka/bin/kafka-topics.sh --create --topic unionflow.contributions.events --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1 --if-not-exists

echo.
echo ====================================
echo Vérification des topics créés
echo ====================================
docker exec kafka /opt/kafka/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

echo.
echo ====================================
echo Détails des topics UnionFlow
echo ====================================
docker exec kafka /opt/kafka/bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 | findstr unionflow

echo.
echo ✅ Topics Kafka créés avec succès !
pause