调用 GetMetadata 时禁用自动主题创建

为避免 Kafka 自动创建主题，需要禁用代理配置中的 auto.create.topics.enable。通过将此设置更新为 false，当尝试获取不存在的主题时，Kafka 不会自动创建该主题。这样可以防止在不需要时意外创建主题。

我正在为我的 kafka 客户端使用 confluence golang。我使用 adminclient 在 kafka 集群中创建/删除/获取主题。这是我初始化 adminclient 的代码

adminclient, err := kafka.newadminclient(&kafka.configmap{
    "bootstrap.servers": 127.0.0.1:9092,
})

之后，我使用这个类来创建并获取kafka集群中的所有主题。以下是创建主题的代码：

ctx, cancel := context.withcancel(context.background())
defer cancel()

results, err := adminclient.createtopics(
    ctx,
    []kafka.topicspecification{{
        topic:             topic,
        numpartitions:     numpartitions,
        replicationfactor: replicationfactor}},
    kafka.setadminoperationtimeout(timeout),
)

之后，我再次获得主题信息：

result, err := adminClient.GetMetadata(&topic, false, 1000)

问题是：如果我得到一个以前不存在的主题，kafka会自动创建该主题。这是我不想要的行为。请告诉我如何解决这个问题。

解决方案

要禁用自动创建主题，您应该更新代理配置，将 auto.create.topics.enable 设为 false。看看the docs或者这个page

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。