Authorisation Error 📌 🆒

It sounds like you're looking for a new to handle Authorisation Errors when a Producer tries to send data to a Kafka topic.

This feature would sit within your Producer client to ensure that errors are handled gracefully rather than just crashing your data pipeline.

: Instead of a generic error, the feature would log the specific Principal (user) and Resource (topic) that failed, making it much faster for your DevOps team to fix the ACLs (Access Control Lists) . Authorisation Error

: 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

: Before a message is sent, the client checks if the user has Write permissions for that topic. It sounds like you're looking for a new

Does this sound like the kind of feature you had in mind, or

[Error while producing messages with authorization enabled] #3011 : If a producer is unauthorized to write

: Make sure your JAAS config (username/password/SSL) is correct, as authorization can't happen if the broker doesn't know who you are.