Confluent go client - 如何在集群上创建主题？

Question

我们正在编写集成测试用例，使用 confluent kafka producer api 生成消息，然后使用 consumer api 使用本地 kafka docker 容器设置（来自 docker 映像 confluentinc/cp-kafka:6.2.0）。

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

---

根据汇合documentation：

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

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

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

Answer 1

我不确定您为什么要查看 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