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

KIP-204 — Adding records deletion operation to the new Admin Client API

Accepted Kafka 1.1 Admin

Adds `deleteRecords(Map<TopicPartition, RecordsToDelete>)` to the new Java `AdminClient` API, exposing the existing `DeleteRecordsRequest` (API key 21) that was previously accessible only via the legacy Scala admin client. The new `AdminClient` introduced in KIP-117 lacked record deletion support, forcing users to fall back to the deprecated Scala tool or rely on time-based retention.

Details

AuthorPaolo Patierno
StatusAccepted
Kafka Version1.1
JIRAKAFKA-5925
WikiView on Apache Wiki
Created2017-09-18
Last Modified2017-11-15
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.