我在用Kafka的主题自动创建。有些主题需要压缩，有些则不需要。在自动创建主题时是否可以指定自定义选项；或者在我消费或生产之前，我需要测试它的存在并用所需的选项“手动”创建它吗？致以最诚挚的问候
n3h0vuf21#
启用自动创建主题允许您写入不存在的主题。你唯一能在你的Kafka中定义的就是主题的名字。该主题的所有配置都将根据主题的默认设置（也称为服务器默认属性）进行设置。在有关主题配置的文档中，您将找到相应的配置名称，例如主题配置的服务器默认属性 cleanup.policy 是代理配置 log.cleanup.policy .如果您需要完全控制检查主题是否存在，并以编程方式使用特定配置创建主题，您可以使用adminclient。
cleanup.policy
log.cleanup.policy
1条答案
按热度按时间n3h0vuf21#
启用自动创建主题允许您写入不存在的主题。你唯一能在你的Kafka中定义的就是主题的名字。
该主题的所有配置都将根据主题的默认设置（也称为服务器默认属性）进行设置。
在有关主题配置的文档中，您将找到相应的配置名称，例如主题配置的服务器默认属性
cleanup.policy是代理配置log.cleanup.policy.如果您需要完全控制检查主题是否存在，并以编程方式使用特定配置创建主题，您可以使用adminclient。