From 16a0b3155fdeebe80295fcfb0f32d75af74dcb1a Mon Sep 17 00:00:00 2001
From: Swen Wenzel <5111028+swenzel@users.noreply.github.com>
Date: Thu, 17 Sep 2020 18:17:35 +0200
Subject: Feature: delete consumergroups (#2040)

* Add consumergroup related errors
* Add DeleteGroups to protocol.admin
* Implement delete_groups feature on KafkaAdminClient
---
 kafka/errors.py | 12 ++++++++++++
 1 file changed, 12 insertions(+)

(limited to 'kafka/errors.py')

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
 
-- 
cgit v1.2.1