conduktor.io ↗

Kafka DeleteTopics Request Wire Format v4 — 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 v4
TopicNames []string
TimeoutMs int32 · 4B
tagged var

Schema & Example

Schema
{
  "TopicNames": [string],
  "TimeoutMs": int32
}
Example
{
  "TopicNames": ["value-1", "value-2"],
  "TimeoutMs": 30000
}