Как получить несколько подписок в сараме - PullRequest
0 голосов
/ 28 мая 2018

Кто-то знает, как создать темы с несколькими подписками в Apache Kafka с помощью Sarama

У меня простой потребитель, и мне нужно подписаться на три разные темы

topic := "Payments" // need to be "Payments","System","Orders"

consumer, err := master.ConsumePartition(topic, 0, sarama.OffsetOldest)
if err != nil {
    panic(err)
}

1 Ответ

0 голосов
/ 22 июня 2018

Sarama Cluster помогли мне

    brokers := []string{"127.0.0.1:9092"}
    topics := []string{"my_topic", "other_topic"}
    consumer, err := cluster.NewConsumer(brokers, "my-consumer-group", topics, config)
    if err != nil {
        panic(err)
    }
    defer consumer.Close()
...