2016-11-10 79 views
3

我們有一個要求,要求刪除/清除主題內任何給定分區的數據。我正在使用Kafka 0.10.0.1。有什麼辦法可以根據需要刪除整個分區內容嗎?如果是,那麼如何。我發現我們可以使用日誌壓縮爲一個密鑰發佈空消息並將其刪除,但除此之外還有什麼方法可以實現刪除?我可以刪除卡夫卡分區版本0.10.0.1

回答

2

Kafka目前不支持減少某個主題的分區數量,因此不提供直接用於直接刪除分區的開箱即用工具。

+0

原來的問題實際上是問「我可以刪除單個分區的數據」。例如。如果我已將數據生成到分區0和1,我可以刪除分區1中的所有* data *並將其偏移量重置爲0。 – Warren