[Enhancement] Improve kafka group authorization failed message in routine load (backport #46136) #48512
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Why I'm doing:
What I'm doing:
Fixes #issue
What type of PR is this:
Does this PR entail a change in behavior?
If yes, please specify the type of change:
Checklist:
Bugfix cherry-pick branch check:
This is an automatic backport of pull request #46136 done by [Mergify](https://mergify.com). ## Why I'm doing: ``` ErrorReason{errCode = 4, msg='Job failed to fetch all current partition with error [err: Broker: Topic authorization failed, BE: TNetworkAddress(hostname:10.0.7.100, port:8060)]'}
[2024-05-23 16:19:37] [task id: cc6fc6c9-e9e6-4a3f-ad3a-190a1f10a633] [txn id: -1] previous task aborted because of FindCoordinator response error: Group authorization failed.
ErrorReason{errCode = 4, msg='Job failed to fetch all current partition with error [failed to get kafka topic meta, err: Broker: Topic authorization failed. You should add READ permission for this topic: users in topic ACLs, BE: TNetworkAddress(hostname:10.0.7.100, port:8060)]'}
[2024-07-11 02:53:30] [task id: 364c7947-c884-446f-9d1e-b1eeafb1325f] [txn id: -1] previous task aborted because of kafka consume failed, err: Fetch from broker 1 failed: Broker: Topic authorization failed. You should add READ permission for this topic: users in topic ACLs
[2024-07-11 02:55:41] [task id: bee6bf6f-9606-411f-b341-2611ee943c00] [txn id: -1] previous task aborted because of kafka consume failed, err: FindCoordinator response error: Group authorization failed.. You should add or modify the consumer group 'wyb_consume_group_3' with READ permission for this topic: users in consumer group ACLs and set the routine load job with
property.group.id
property