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.
Wire Diagram
Request Header
message_size
int32 · 4B
api_key
int16 · 2B
api_version
int16 · 2B
correlation_id
int32 · 4B
client_id
string
DeleteTopicsRequest v1
TopicNames
[]string
TimeoutMs
int32 · 4B
Schema & Example
Schema { "TopicNames": [string], "TimeoutMs": int32 }
Example { "TopicNames": ["value-1", "value-2"], "TimeoutMs": 30000 }