[MINOR]: Update asyncapi Kafka consumer to use bootstrap server url (#…

…2913)
confluentinc · Oct 25, 2024 · 69941b8 · 69941b8
1 parent 3c70fb9
commit 69941b8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/internal/asyncapi/account_details.go b/internal/asyncapi/account_details.go
@@ -38,6 +38,7 @@ type accountDetails struct {
 	clusterCreds            *config.APIKeyPair
 	consumer                *ckgo.Consumer
 	kafkaUrl                string
+	kafkaBootstrapUrl       string
 	schemaRegistryUrl       string
 	srClient                *schemaregistry.Client
 	subjects                []string

diff --git a/internal/asyncapi/command_export.go b/internal/asyncapi/command_export.go
@@ -227,7 +227,7 @@ func (c *command) getAccountDetails(cmd *cobra.Command, flags *flags) (*accountD
 
 	// Create Consumer
 	if flags.consumeExamples {
-		details.consumer, err = createConsumer(details.kafkaUrl, details.clusterCreds, flags.group)
+		details.consumer, err = createConsumer(details.kafkaBootstrapUrl, details.clusterCreds, flags.group)
 		if err != nil {
 			return nil, err
 		}
@@ -440,7 +440,9 @@ func (c *command) getClusterDetails(details *accountDetails, flags *flags) error
 	details.kafkaClusterId = cluster.ID
 	details.schemaRegistryClusterId = clusters[0].GetId()
 	details.clusterCreds = clusterCreds
+	// kafkaUrl is used in exported file, while kafkaBootstrapUrl is used to create Kafka consumer
 	details.kafkaUrl = kafkaREST.CloudClient.GetUrl()
+	details.kafkaBootstrapUrl = cluster.Bootstrap
 	details.schemaRegistryUrl = clusters[0].Spec.GetHttpEndpoint()
 	details.topics = topics.Data