sarama - 在 sarama 中创建 Kafka 主题

Question

是否可以在sarama中创建kafka主题？我知道 java API 允许您创建主题，但我找不到任何有关如何在 sarama 中创建主题的信息。如果可能的话，我应该使用哪个 api 的示例或解释会很棒提前致谢

Answer 1

事实上，在较新版本的 Sarama 中，您可以使用 ClusterAdmin来创建话题。您可以在下面找到示例代码:

package main

import (
    "github.com/Shopify/sarama" // Sarama 1.22.0
    "log"
)

func main() {
    brokerAddrs := []string{"localhost:9092"}
    config := sarama.NewConfig()
    config.Version = sarama.V2_1_0_0
    admin, err := sarama.NewClusterAdmin(brokerAddrs, config)
    if err != nil {
        log.Fatal("Error while creating cluster admin: ", err.Error())
    }
    defer func() { _ = admin.Close() }()
    err = admin.CreateTopic("topic.test.1", &sarama.TopicDetail{
        NumPartitions:     1,
        ReplicationFactor: 1,
    }, false)
    if err != nil {
        log.Fatal("Error while creating topic: ", err.Error())
    }
}