remove flipping SASL

Author: izadoesdev

apps/basket/src/lib/kafka.test.ts

@@ -20,11 +20,6 @@ describe('Kafka Producer and Consumer', () => {
 				initialRetryTime: 100,
 				retries: 8,
 			},
-			sasl: {
-				mechanism: 'scram-sha-256',
-				username: process.env.KAFKA_USER as string,
-				password: process.env.KAFKA_PASSWORD as string,
-			},
 		});
 
 		producer = kafka.producer();

apps/basket/src/lib/producer.test.ts

@@ -16,11 +16,6 @@ describe('Producer Module', () => {
 		kafka = new Kafka({
 			clientId: 'producer-test',
 			brokers: [KAFKA_BROKERS],
-			sasl: {
-				mechanism: 'scram-sha-256',
-				username: process.env.KAFKA_USER as string,
-				password: process.env.KAFKA_PASSWORD as string,
-			},
 			retry: {
 				initialRetryTime: 100,
 				retries: 8,

apps/basket/src/lib/producer.ts

@@ -66,11 +66,6 @@ if (BROKER) {
 		brokers: [BROKER],
 		connectionTimeout: 5000,
 		requestTimeout: KAFKA_TIMEOUT,
-		sasl:{
-			mechanism: 'scram-sha-256',
-			username: process.env.KAFKA_USER as string,
-			password: process.env.KAFKA_PASSWORD as string,
-		}
 	});
 	producer = kafka.producer({
 		allowAutoTopicCreation: true,

infra/env.example

@@ -7,8 +7,6 @@ CLICKHOUSE_URL=http://clickhouse:8123
 REDPANDA_LOG_LEVEL=info
 REDPANDA_ADVERTISED_HOST=localhost
 REDPANDA_BROKER=redpanda:9092
-VECTOR_KAFKA_USER=vector-agent
-VECTOR_KAFKA_PASSWORD=super_secret_password
 
 # Vector Configuration
 VECTOR_LOG=info

infra/ingest/docker-compose.yml

@@ -62,12 +62,12 @@ services:
     volumes:
       - ./vector.yaml:/etc/vector/vector.yaml:ro
     environment:
-      CLICKHOUSE_USER: ${CLICKHOUSE_USER}
-      CLICKHOUSE_PASSWORD: ${CLICKHOUSE_PASSWORD}
+      CLICKHOUSE_USER: ${CLICKHOUSE_USER:-default}
+      CLICKHOUSE_PASSWORD: ${CLICKHOUSE_PASSWORD:-defaultpass}
       CLICKHOUSE_URL: ${CLICKHOUSE_URL:-http://clickhouse:8123}
       VECTOR_LOG: ${VECTOR_LOG:-info}
-      VECTOR_KAFKA_USER: ${VECTOR_KAFKA_USER}
-      VECTOR_KAFKA_PASSWORD: ${VECTOR_KAFKA_PASSWORD}
+      VECTOR_KAFKA_USER: ${VECTOR_KAFKA_USER:-vector-agent}
+      VECTOR_KAFKA_PASSWORD: ${VECTOR_KAFKA_PASSWORD:-super_secret_password}
       REDPANDA_BROKER: ${REDPANDA_BROKER:-redpanda:9092}
     networks:
       - databuddy

infra/ingest/vector.yaml

@@ -2,10 +2,6 @@ sources:
   redpanda:
     type: kafka
     bootstrap_servers: "${REDPANDA_BROKER}"
-    sasl:
-      mechanism: "scram-sha-256"
-      username: "${VECTOR_KAFKA_USER}"
-      password: "${VECTOR_KAFKA_PASSWORD}"
     group_id: vector-analytics
     topics:
       - analytics-events