You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug
I have created an admin client for Kafka. I am able to use this for listTopics, listGroups & describeGroups without any problem. But as soon as I try describeAcls, it ends up in below error:
To Reproduce
Here is the piece of code that fails:
const kafka = new Kafka({
clientId: "portal-app",
brokers,
ssl: true, // Enable SSL
sasl: {
mechanism: "scram-sha-512",
username,
password,
},
});
const admin = kafka.admin();
console.log("Connecting to Kafka broker...");
await admin.connect();
// get ACLS for a topic
const topic = "my.topic";
const acl = await admin.describeAcls({
resourceType: AclResourceTypes.TOPIC,
resourceName: topic,
resourcePatternType: ResourcePatternTypes.LITERAL,
operation: AclOperationTypes.ALL,
permissionType: AclPermissionTypes.ALLOW,
});
Describe the bug
I have created an admin client for Kafka. I am able to use this for listTopics, listGroups & describeGroups without any problem. But as soon as I try describeAcls, it ends up in below error:
{
"level": "ERROR",
"timestamp": "2025-02-07T08:27:32.998Z",
"logger": "kafkajs",
"message": "[Connection] Response DescribeAcls(key: 29, version: 1)",
"broker": "b-1.i--------------------:9096",
"clientId": "portal-app",
"error": "Cluster authorization failed",
"correlationId": 5,
"size": 260
}
To Reproduce
Here is the piece of code that fails:
const kafka = new Kafka({
clientId: "portal-app",
brokers,
ssl: true, // Enable SSL
sasl: {
mechanism: "scram-sha-512",
username,
password,
},
});
Expected behavior
It should be able to describe the acls
Environment:
Additional context
There is zookeeper used to define ACLs
The text was updated successfully, but these errors were encountered: