Skip to content

Commit cdc927e

Browse files
authored
fix: omit {Cluster,Topic}AuthorizedOperations (#821)
kafka-go doesn't appear to actually make use of either the ClusterAuthorizedOperations nor the per-topic TopicAuthorizedOperations responses anywhere in its code, so this is causing unecessary load on the brokers as this is a non-trivial thing for them to determine each time. Contributes-to: #818 Signed-off-by: Dominic Evans <[email protected]>
1 parent 37ab7b1 commit cdc927e

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

transport.go

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -585,10 +585,7 @@ func (p *connPool) discover(ctx context.Context, wake <-chan event) {
585585
p.update(ctx, nil, err)
586586
} else {
587587
res := make(async, 1)
588-
req := &meta.Request{
589-
IncludeClusterAuthorizedOperations: true,
590-
IncludeTopicAuthorizedOperations: true,
591-
}
588+
req := &meta.Request{}
592589
deadline, cancel := context.WithTimeout(ctx, p.metadataTTL)
593590
c.reqs <- connRequest{
594591
ctx: deadline,

0 commit comments

Comments
 (0)