File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -329,6 +329,8 @@ func (e Error) Title() string {
329
329
return "Unsupported Compression Type"
330
330
case MemberIDRequired :
331
331
return "Member ID Required"
332
+ case FencedInstanceID :
333
+ return "Fenced Instance ID"
332
334
case EligibleLeadersNotAvailable :
333
335
return "Eligible Leader Not Available"
334
336
case ElectionNotNeeded :
@@ -538,6 +540,8 @@ func (e Error) Description() string {
538
540
return "the requesting client does not support the compression type of given partition"
539
541
case MemberIDRequired :
540
542
return "the group member needs to have a valid member id before actually entering a consumer group"
543
+ case FencedInstanceID :
544
+ return "the broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id"
541
545
case EligibleLeadersNotAvailable :
542
546
return "eligible topic partition leaders are not available"
543
547
case ElectionNotNeeded :
You can’t perform that action at this time.
0 commit comments