Apply PR reviews

Author: rkpattnaik780

locales/cmd/kafka/common/active.en.toml

@@ -19,7 +19,6 @@ description = 'Error message when list of Kafka instances could not be fetched'
 one = 'unable to list Kafka instances'
 
 [kafka.common.input.instanceName.message]
-description = 'title for the Partitions input'
 one = 'Select Kafka instance to connect:'
 
 [kafka.common.log.info.noKafkaInstances]

pkg/cmd/kafka/use/use.go

@@ -73,7 +73,7 @@ func NewUseCommand(f *factory.Factory) *cobra.Command {
 func runUse(opts *Options) error {
 
 	if opts.interactive {
-		// run the create command interactively
+		// run the use command interactively
 		err := runInteractivePrompt(opts)
 		if err != nil {
 			return err
@@ -155,7 +155,7 @@ func runInteractivePrompt(opts *Options) error {
 		return err
 	}
 
-	opts.name = *selectedKafka.Name
+	opts.name = selectedKafka.GetName()
 
 	return nil
 }

pkg/kafka/kafka.go

@@ -12,10 +12,14 @@ import (
 	"github.com/bf2fc6cc711aee1a0c2a/cli/pkg/logging"
 )
 
+const (
+	queryLimit = "1000"
+)
+
 func InteractiveSelect(connection connection.Connection, logger logging.Logger) (*kasclient.KafkaRequest, error) {
 	api := connection.API()
 
-	response, _, apiErr := api.Kafka().ListKafkas(context.Background()).Execute()
+	response, _, apiErr := api.Kafka().ListKafkas(context.Background()).Size(queryLimit).Execute()
 
 	if apiErr.Error() != "" {
 		return nil, fmt.Errorf("%v: %w", localizer.MustLocalizeFromID("kafka.common.error.couldNotFetchKafkas"), apiErr)