doru52911 2018-05-28 14:37
浏览 296
已采纳

如何在Sarama获得多个订阅

Someone knows how to make a multi-subscription topics in Apache Kafka using Sarama

I have a simple consumer, and I need to subscribe to three different topics

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

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

1条回答 默认 最新

  • dpp89959 2018-06-22 07:52
    关注

    Sarama Cluster helped for me

        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()
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 python爬取bilibili校园招聘网站
  • ¥30 求解达问题(有红包)
  • ¥15 请解包一个pak文件
  • ¥15 不同系统编译兼容问题
  • ¥100 三相直流充电模块对数字电源芯片在物理上它必须具备哪些功能和性能?
  • ¥30 数字电源对DSP芯片的具体要求
  • ¥20 antv g6 折线边如何变为钝角
  • ¥30 如何在Matlab或Python中 设置饼图的高度
  • ¥15 nginx中的CORS策略应该如何配置
  • ¥30 信号与系统实验:采样定理分析