Kafka:使用选项自动创建主题

Kafka: auto create topic with options

我在 Kafka 中使用自动创建主题。有些主题需要压缩,有些则不需要。

是否可以在自动创建主题时指定自定义选项;或者我是否需要测试是否存在并在消费或生产之前使用所需的选项创建它'manually'?

此致

启用自动创建主题允许您写入不存在的主题。您唯一可以在 KafkaProducer 中定义的是主题的 name

该主题的所有配置将根据您的主题默认设置进行设置,也称为 服务器默认设置 属性

Topic Configuration 的文档中,您将找到相应的配置名称,例如主题配置 cleanup.policy 的服务器默认值 属性 是代理配置 log.cleanup.policy

如果您需要完全控制检查主题是否存在并以编程方式创建具有特定配置的主题,您可以使用 AdminClient.