Confluence go 客户端 - 如何在集群上创建主题？

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《Confluence go 客户端 - 如何在集群上创建主题？》，聊聊，我们一起来看看吧！

我们正在编写集成测试用例，以使用融合的 kafka 生产者 api 生成消息，然后使用消费者 api 和本地 kafka docker 容器设置进行消费（来自 docker 镜像 confluenceinc/cp-kafka:6.2.0）。

在生成消息之前，我们需要在 kafka 容器中的集群上创建一个主题。

根据汇合文档：

POST /clusters/{cluster_id}/topics 创建一个新主题。

集群 id 的值应该是多少？是否有不同的 api 来创建集群 id？

如果没有api，我们可以使用另一个docker容器创建kafka主题吗？

正确答案

我不确定您为什么要查看 go 客户端的 rest 代理文档。您可以在 go 代码中完成这一切，无需其他容器

您需要的是一个 adminclient，它像生产者/消费者一样使用引导服务器

a, err := kafka.NewAdminClient(&kafka.ConfigMap{"bootstrap.servers": broker})
...
results, err := a.CreateTopics( ... )

例如https://github.com/confluentinc/confluent-kafka-go/blob/master/examples/admin_create_topic/admin_create_topic.go

理论要掌握，实操不能落！以上关于《Confluence go 客户端 - 如何在集群上创建主题？》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！