apache-kafka - Kafka：使用选项自动创建主题

Question

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

自动创建主题时是否可以指定自定义选项；还是我需要在消费或生产之前测试存在并使用所需选项“手动”创建它？

最好的祝福

标签： apache-kafkakafka-consumer-apikafka-producer-apikafka-topic

Answer 1

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

该主题的所有配置都将根据您对主题的默认设置进行设置，也称为Server Default Property。

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

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