While I can't build the code directly into your app, I can suggest a high-level feature design for a "Smart Authorization Guard" that would help your system handle these errors automatically. Feature Proposal: Smart Authorization Guard
: If an authorization error occurs, the feature could automatically trigger a "Request Access" workflow or alert admins through tools like Slack or PagerDuty with the specific missing role details. Authorisation Error
Does this sound like the kind of feature you had in mind, or While I can't build the code directly into
: If a producer is unauthorized to write to a mission-critical topic, the feature could temporarily route those messages to a safe "quarantine" topic or local storage so no data is lost during the downtime. How to Implement This Today How to Implement This Today It sounds like
It sounds like you're looking for a new to handle Authorisation Errors when a Producer tries to send data to a Kafka topic.
The most common version of this is the TOPIC_AUTHORIZATION_FAILED error, which usually happens because a service account or user doesn't have the right permissions to write to a specific topic.