Skip to content

Commit 4b76d41

Browse files
author
Swen Wenzel
committed
add consumergroup related errors
1 parent 64253aa commit 4b76d41

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

kafka/errors.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -449,6 +449,18 @@ class SecurityDisabledError(BrokerResponseError):
449449
description = 'Security features are disabled.'
450450

451451

452+
class NonEmptyGroupError(BrokerResponseError):
453+
errno = 68
454+
message = 'NON_EMPTY_GROUP'
455+
description = 'The group is not empty.'
456+
457+
458+
class GroupIdNotFoundError(BrokerResponseError):
459+
errno = 69
460+
message = 'GROUP_ID_NOT_FOUND'
461+
description = 'The group id does not exist.'
462+
463+
452464
class KafkaUnavailableError(KafkaError):
453465
pass
454466

0 commit comments

Comments
 (0)