kafka connect

Author: AhmetFurkanDEMIR

.github/workflows/ansible_kafka_connect.yaml

@@ -43,29 +43,9 @@ jobs:
               echo \"\$SSH_PRIVATE_KEY\" > ~/.ssh/trendyol-kafka-key.pem
               chmod 600 ~/.ssh/trendyol-kafka-key.pem
 
-              # Inventory oluştur
+              # Inventory ve .env oluştur (S3'ten çeker, env var'larla merge eder)
               bash kafka_connect/generate-inventory.sh
 
-              # .env dosyası oluştur
-              cat > kafka_connect/.env <<EOF
-# Kafka Broker Configuration
-KAFKA_BOOTSTRAP_SERVERS=\$(grep KAFKA_BOOTSTRAP_SERVERS kafka_connect/.env | cut -d'=' -f2)
-KAFKA_SECURITY_PROTOCOL=\$KAFKA_SECURITY_PROTOCOL
-KAFKA_SASL_MECHANISM=\$KAFKA_SASL_MECHANISM
-KAFKA_SASL_USERNAME=\$KAFKA_SASL_USERNAME
-KAFKA_SASL_PASSWORD=\$ADMIN_PASSWORD
-
-# SSL Configuration
-SSL_KEYSTORE_PASSWORD=\$SSL_KEYSTORE_PASSWORD
-SSL_TRUSTSTORE_PASSWORD=\$SSL_TRUSTSTORE_PASSWORD
-
-# Kafka Connect Configuration
-CONNECT_PUBLIC_DNS=\$(grep CONNECT_PUBLIC_DNS kafka_connect/.env | cut -d'=' -f2)
-
-# JWT Token for FastAPI Authentication
-JWT_TOKEN=\$JWT_TOKEN
-EOF
-
               # Test ping
               ansible all -i kafka_connect/inventory.yml -m ping
 

kafka_connect/generate-inventory.sh

@@ -158,4 +158,4 @@ echo ""
 echo "📊 Configuration:"
 echo "   Kafka Connect: ${CONNECT_PUBLIC_DNS}"
 echo "   Bootstrap Servers: ${KAFKA_BOOTSTRAP_SERVERS}"
-echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━"
+echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━"