It sounds like you're looking for a new to handle Authorisation Errors when a Producer tries to send data to a Kafka topic.
: Make sure your JAAS config (username/password/SSL) is correct, as authorization can't happen if the broker doesn't know who you are.
If you are currently facing this error, you can resolve it by following these steps:
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
[Error while producing messages with authorization enabled] #3011
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.
: Set your authorizer logs to DEBUG in your broker's log4j.properties to see exactly which user is being denied.
It sounds like you're looking for a new to handle Authorisation Errors when a Producer tries to send data to a Kafka topic.
: Make sure your JAAS config (username/password/SSL) is correct, as authorization can't happen if the broker doesn't know who you are. Authorisation Error
If you are currently facing this error, you can resolve it by following these steps: It sounds like you're looking for a new
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 Authorisation Error
[Error while producing messages with authorization enabled] #3011
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.
: Set your authorizer logs to DEBUG in your broker's log4j.properties to see exactly which user is being denied.