使用管理 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 天之间的任何值。