conduktor.io ↗

Kafka DeleteTopics Request Wire Format v6 — Binary Protocol Layout

What is DeleteTopics?

Permanently removes topics and their data via kafka-topics.sh --delete. Returns TOPIC_AUTHORIZATION_FAILED if the caller lacks DELETE permission; in clusters with auto.create.topics.enable=false, deleting a topic that a consumer references causes UNKNOWN_TOPIC_OR_PARTITION until reconfiguration.

Related Errors

NOT_CONTROLLER · THROTTLING_QUOTA_EXCEEDED · TOPIC_DELETION_DISABLED

Wire Diagram

Request Header · flexible
message_size int32 · 4B
api_key int16 · 2B
api_version int16 · 2B
correlation_id int32 · 4B
client_id string (compact)
tagged var
DeleteTopicsRequest v6
Topics array
TimeoutMs int32 · 4B
tagged var
Name? string (compact)
TopicId uuid · 16B
tagged var

Schema & Example

Schema
{
  "Topics": [{
      "Name": string?,
      "TopicId": uuid
  }],
  "TimeoutMs": int32
}
Example
{
  "Topics": [{
      "Name": "orders",
      "TopicId": "550e8400-e29b-41d4-a716-446655440000"
  }],
  "TimeoutMs": 30000
}