diff --git a/kafka/kafka_acls.go b/kafka/kafka_acls.go index ec689de8..a81f166d 100644 --- a/kafka/kafka_acls.go +++ b/kafka/kafka_acls.go @@ -146,18 +146,12 @@ func (c *Client) DeleteACL(s StringlyTypedACL) error { return err } - matchingAclCount := 0 - for _, r := range res.FilterResponses { - matchingAclCount += len(r.MatchingAcls) if r.Err != sarama.ErrNoError { return r.Err } } - if matchingAclCount == 0 { - return fmt.Errorf("There were no acls matching this filter") - } return nil }