Feature: delete consumergroups (#2040)

* Add consumergroup related errors
* Add DeleteGroups to protocol.admin
* Implement delete_groups feature on KafkaAdminClient

1 files changed, 12 insertions, 0 deletions

diff --git a/kafka/errors.py b/kafka/errors.py
index 2c1df82..b33cf51 100644
--- a/kafka/errors.py
+++ b/kafka/errors.py
@@ -449,6 +449,18 @@ class SecurityDisabledError(BrokerResponseError):
     description = 'Security features are disabled.'
 
 
+class NonEmptyGroupError(BrokerResponseError):
+    errno = 68
+    message = 'NON_EMPTY_GROUP'
+    description = 'The group is not empty.'
+
+
+class GroupIdNotFoundError(BrokerResponseError):
+    errno = 69
+    message = 'GROUP_ID_NOT_FOUND'
+    description = 'The group id does not exist.'
+
+
 class KafkaUnavailableError(KafkaError):
     pass