使用管理 Kafka Java 用戶端 API

如果您使用 Kafka 用戶端 0.11 版或更新版本,或 Kafka Streams 0.10.2.0 版或更新版本,則可以使用 API 來建立及刪除主題。 我們對您建立主題時所容許的設定施加一些限制。 請參閱您可以修改的下列設定。

cleanup.policy

設為 delete (預設值)、compactdelete,compact

retention.ms

預設保留期間是 24 小時。 最短 1 小時,最長 30 天。 請以小時的倍數來指定此值。

在企業方案中,您可以將保留設為任何值。

retention.bytes

在我們捨棄舊日誌區段以釋放空間之前,分割區(由日誌區段所組成)可以成長到的大小上限。

僅限企業方案。 設為大於 10 MB 的任何值。

segment.bytes

日誌的區段檔案大小。

僅限企業方案。 請設為大於 100 KB 的任何值。

segment.index.bytes

將偏移對映至檔案位置的索引大小。

僅限企業方案。 設為 100 kB 到 1 GB 之間的任何值。

segment.ms

在此期間之後,即使區段檔案未滿,Kafka 仍會強制日誌捲動。

僅限企業方案。 設為 5 分鐘到 30 天之間的任何值。