File tree Expand file tree Collapse file tree 4 files changed +8
-4
lines changed
locales/cmd/kafka/consumergroup/delete
pkg/cmd/kafka/consumergroup Expand file tree Collapse file tree 4 files changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -27,4 +27,7 @@ description = 'Info message when user chose not to delete consumer group'
2727one = ' Consumer group delete action was not confirmed. Exiting silently'
2828
2929[kafka .consumerGroup .delete .log .info .consumerGroupDeleted ]
30- one = ' Consumer group with ID "{{.ConsumerGroupID}}" has been deleted from the Kafka instance "{{.InstanceName}}"'
30+ one = ' Consumer group with ID "{{.ConsumerGroupID}}" has been deleted from the Kafka instance "{{.InstanceName}}"'
31+
32+ [kafka .consumerGroup .delete .error .locked ]
33+ one = ' not allowed to delete a consumer group with active members'
Original file line number Diff line number Diff line change 55 "github.com/redhat-developer/app-services-cli/pkg/cmd/factory"
66 "github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/delete"
77 "github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/describe"
8- "github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/list"
98 "github.com/spf13/cobra"
109)
1110
@@ -20,7 +19,7 @@ func NewConsumerGroupCommand(f *factory.Factory) *cobra.Command {
2019 }
2120
2221 cmd .AddCommand (
23- list .NewListConsumerGroupCommand (f ),
22+ // list.NewListConsumerGroupCommand(f),
2423 delete .NewDeleteConsumerGroupCommand (f ),
2524 describe .NewDescribeConsumerGroupCommand (f ),
2625 )
Original file line number Diff line number Diff line change @@ -150,6 +150,8 @@ func runCmd(opts *Options) error {
150150 "Operation" : "delete" ,
151151 },
152152 }))
153+ case 423 :
154+ return errors .New (localizer .MustLocalizeFromID ("kafka.consumerGroup.delete.error.locked" ))
153155 case 500 :
154156 return errors .New (localizer .MustLocalizeFromID ("kafka.consumerGroup.common.error.internalServerError" ))
155157 case 503 :
You can’t perform that action at this time.
0 commit comments