// GetCurrentKafkaInstance returns the Kafka instance set in the currently selected context
GetCurrentKafkaInstance returns the Kafka instance set in the currently selected context
// GetCurrentKafkaInstance returns the Kafka instance set in the currently selected context
func GetCurrentKafkaInstance(f *factory.Factory) (*kafkamgmtclient.KafkaRequest, error) {
	svcContext, err := f.ServiceContext.Load()
	if err != nil {
		return nil, err
	}
	currCtx, err := GetCurrentContext(svcContext, f.Localizer)
	if err != nil {
		return nil, err
	}
	return GetKafkaForServiceConfig(currCtx, f)
}
func GetCurrentKafkaInstance ( f * factory . Factory ) ( * kafkamgmtclient . KafkaRequest , error ) { svcContext , err := f . ServiceContext . Load ( ) if err != nil { return nil , err } currCtx , err := GetCurrentContext ( svcContext , f . Localizer ) if err != nil { return nil , err } return GetKafkaForServiceConfig ( currCtx , f ) }
GetCurrentKafkaInstance returns the Kafka instance set in the currently selected context
GetCurrentKafkaInstance returns the Kafka instance set in the currently selected context