使用管理 Kafka Java 用戶端 API
如果您使用 Kafka 用戶端 0.11 版或更新版本,或 Kafka Streams 0.10.2.0 版或更新版本,則可以使用 API 來建立及刪除主題。 我們對您建立主題時所容許的設定施加一些限制。 請參閱您可以修改的下列設定。
- cleanup.policy
-
設為
delete(預設值)、compact或delete,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 天之間的任何值。