From 21dc10548250aa8c8627fa859f651bb96f34ca18 Mon Sep 17 00:00:00 2001 From: Adam0Brien Date: Tue, 26 Nov 2024 14:44:58 +0000 Subject: [PATCH] test kafka no partition --- test/e2e/kafkaconsumer_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/test/e2e/kafkaconsumer_test.go b/test/e2e/kafkaconsumer_test.go index 9c3ff33d..2004c3a3 100644 --- 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()