Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Kafka Upgrade Config Advisor Flink SQL
conduktor.io ↗

Kafka DeleteAcls Response Wire Format v3 — Binary Protocol Layout

What is DeleteAcls?

Revokes ACL entries via kafka-acls.sh --remove. Returns a list of deleted entries per filter; if the filter matched nothing, it's not an error. Be careful with wildcard filters as they can delete more ACLs than intended.

Wire Diagram

Response Header · flexible
message_size int32 · 4B
correlation_id int32 · 4B
tagged var
DeleteAclsResponse v3
ThrottleTimeMs int32 · 4B
FilterResults array
tagged var
ErrorCode int16 · 2B
ErrorMessage? string (compact)
MatchingAcls array
tagged var
ErrorCode int16 · 2B
ErrorMessage? string (compact)
ResourceType int8 · 1B
ResourceName string (compact)
PatternType int8 · 1B
Principal string (compact)
Host string (compact)
Operation int8 · 1B
PermissionType int8 · 1B
tagged var

Schema & Example

Schema
{
  "ThrottleTimeMs": int32,
  "FilterResults": [{
      "ErrorCode": int16,
      "ErrorMessage": string?,
      "MatchingAcls": [{
          "ErrorCode": int16,
          "ErrorMessage": string?,
          "ResourceType": int8,
          "ResourceName": string,
          "PatternType": int8,
          "Principal": string,
          "Host": string,
          "Operation": int8,
          "PermissionType": int8
      }]
  }]
}
Example
{
  "ThrottleTimeMs": 0,
  "FilterResults": [{
      "ErrorCode": 0,
      "ErrorMessage": "NETWORK_EXCEPTION",
      "MatchingAcls": [{
          "ErrorCode": 0,
          "ErrorMessage": "NETWORK_EXCEPTION",
          "ResourceType": 2,
          "ResourceName": "orders",
          "PatternType": 1,
          "Principal": "User:alice",
          "Host": "broker-1.kafka.local",
          "Operation": 2,
          "PermissionType": 3
      }]
  }]
}