test kafka no partition

Adam0Brien · Nov 26, 2024 · 21dc105 · 21dc105
1 parent 55ac39a
commit 21dc105
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/test/e2e/kafkaconsumer_test.go b/test/e2e/kafkaconsumer_test.go
@@ -94,7 +94,7 @@ func Test_ACMKafkaConsumer(t *testing.T) {
 	kafkaClientCert := os.Getenv("KAFKA_CLIENT_CERT") // Client cert for mutual authentication
 	kafkaClientKey := os.Getenv("KAFKA_CLIENT_KEY")   // Client private key for mutual authentication
 
-	topic := getEnvOrDefault("KAFKA_TOPIC", "kessel-inventory")
+	//topic := getEnvOrDefault("KAFKA_TOPIC", "kessel-inventory")
 
 	config := &kafka.ConfigMap{
 		"bootstrap.servers": kafkaBootstrapServers,
@@ -159,10 +159,10 @@ func Test_ACMKafkaConsumer(t *testing.T) {
 	}
 	defer consumer.Close()
 
-	err = consumer.Subscribe(topic, nil)
-	if err != nil {
-		t.Fatalf("Failed to subscribe to topic: %v", err)
-	}
+	//err = consumer.Subscribe(topic, nil)
+	//if err != nil {
+	//	t.Fatalf("Failed to subscribe to topic: %v", err)
+	//}
 
 	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
 	defer cancel()