From aadd135dca3994186d9c55e4417c862a973a5ae6 Mon Sep 17 00:00:00 2001 From: Peter Dannemann Date: Tue, 12 Dec 2023 13:35:54 -0500 Subject: [PATCH] rearrange plan for deletion --- pkg/acl/acl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/acl/acl.go b/pkg/acl/acl.go index 5ee6e73a..fdac3172 100644 --- a/pkg/acl/acl.go +++ b/pkg/acl/acl.go @@ -166,7 +166,7 @@ func (a *ACLAdmin) Delete(ctx context.Context, filter kafka.DeleteACLsFilter) er return fmt.Errorf("No ACL matches filter:\n%+v", formatACLs(filter)) } - log.Infof("%d ACLs in the cluster match the filter provided", len(clusterACLs)) + log.Infof("The following ACLs in the cluster are planned for deletion:\n%+v", formatACLInfos(clusterACLs)) if a.config.DryRun { log.Infof("Would delete ACLs:\n%+v", formatACLInfos(clusterACLs)) @@ -174,7 +174,7 @@ func (a *ACLAdmin) Delete(ctx context.Context, filter kafka.DeleteACLsFilter) er } // This isn't settable by the CLI for safety measures but allows for testability - confirm, err := util.Confirm(fmt.Sprintf("Delete ACLs?\n%+v", formatACLInfos(clusterACLs)), a.config.SkipConfirm) + confirm, err := util.Confirm("Delete ACLs?", a.config.SkipConfirm) if err != nil { return err }