func()

in kafka/manager.go [331:343]

• 13 lines of code
• 4 McCabe index (conditional complexity)

func (m *Manager) CreateACLs(ctx context.Context, acls *kadm.ACLBuilder) error {
	res, err := m.adminClient.CreateACLs(ctx, acls)
	if err != nil {
		return fmt.Errorf("failed to create ACLs: %w", err)
	}
	var errs []error
	for _, r := range res {
		if r.Err != nil {
			errs = append(errs, r.Err)
		}
	}
	return errors.Join(errs...)
}