回答情况：
提问时间：
问题标签：
我是新来的，我也在努力模拟这个电话：sarama.NewConsumerGroup(brokers, group, config)type MyMockedObjectReciever) (sarama.ConsumerGroup, error) { return args.Get(0)(sarama.ConsumerGroup), args.Error(1)
// mo
浏览 4提问于2020-06-15得票数 0
回答已采纳
package main
"fmt"
)
if err !partition := range partitionList {
pc, er
浏览 7提问于2021-12-14得票数 0
我是第一次尝试用Sarama库对使用Kafka消息的开源库进行一些调整。我在同一个应用程序中做了一些工作，使用我在网上找到的一些例子来实现sarama NewConsumerGroup包。")
sarama.Log
浏览 3修改于2019-12-25得票数 2
回答已采纳
版本Kafka - 5.4.6-2.12sarama.Logger = log.New(os.Stderr, "[Sarama] ", log.LstdFlags) "kafka1:9092",}
cfg.Version= sarama.V2_4_0_0
admin,
浏览 10提问于2022-05-06得票数 1
回答已采纳
有人知道如何使用Sarama在Apache Kafka中创建多订阅主题。Payments" // need to be "Payments","System","Orders"
consumer, err := master.ConsumePartition(topic, 0, sarama.OffsetOldest
浏览 5修改于2018-05-29得票数 0
回答已采纳
我使用sarama(1.27) ClusterAdmin来管理kafka1.1.0中的主题。我管理kafka主题的应用程序是作为REST服务运行的。
浏览 34修改于2020-09-04得票数 0
因此，我试图将Kafka用于我的应用程序，该应用程序有一个生产者将操作记录到Kafka MQ中，而使用者将它从我的应用程序在Go中的MQ.Since中读取出来，我正在使用Shopify Sarama来实现这一点用于消费者连接的当前代码：
master, err := sarama.NewConsumer([]string{brokerConnect},
浏览 0提问于2015-04-01得票数 3
回答已采纳
其次是“调优”Sarama代码以使用版本0.10.x作为最低版本，使我能够使用所有0.10.x API/功能。
我仍然在想，为什么这个版本不是从我连接的Kafka代理中获取的？我清楚地看到了在sarama.Config.Version中设置或定义的版本，但是一旦连接到代理，我就找不到任何东西来更新这个值？
浏览 5修改于2017-09-26得票数 0
是否有可能对Sarama消费者做同样的事情？ 假设我在读到偏移量550，我的消费者崩溃了5分钟，我们现在是偏移量700，但我想从偏移量550继续消费。 有没有可能不需要自己去拯救国家呢？我找到了sarama.OffsetNewest/Oldest但那不是我要找的..。
浏览 44提问于2019-04-11得票数 2
回答已采纳
我正在尝试使用sarama获取kafka生产者/消费者指标。但我找不到任何关于如何做到这一点的例子。有人能提供一个示例实现示例吗？ saramaConfig := sarama.NewConfig() client, err := sarama.NewClient(<brokerAddresses>, saramaConfig)
if err !
浏览 11提问于2021-06-28得票数 0
当我产生一条消息时，我正在使用Go中编写的Sarama库从错误通道读取。整个代码如下所示，它包含在一个函数中：go func() {
for err := range saramaProducer.Errors() {
浏览 5修改于2018-02-02得票数 0
回答已采纳
ConsumeClaim(会话sarama.ConsumerGroupSession，索赔sarama.ConsumerGroupClaim)错误{消息:= range claim.Messages()this.handler( message ) session.MarkMessage(message，"") }返回nil } ctx := context.Background() conf := sarama.NewConfig() conf.Version = sarama.V2___0 conf
浏览 0修改于2019-07-16得票数 3
但是我在shopify sarama找不到可以用来提交一条或一批消息的方法或api，请帮帮忙
浏览 9修改于2020-11-25得票数 1
producer,func (c *kafkaClient) init() { c.config = *config c.producer, err = sarama.NewAsyncProducermessage to the Kafka topic, W
浏览 0提问于2018-10-08得票数 4
回答已采纳
当我在不同的进程中对相同的主题和相同的分区使用sarama.ConsumePartition时，行为是像共享默认组还是类似于使用唯一的组？
浏览 6提问于2022-05-10得票数 1
我有一个想要将consumer_group_2重命名为consumer_group的用例。我之所以这样做，是因为我想从consumer_group_2的最后一个偏移量开始消费，但我想将组id从consumer_group重命名为consumer_group_2
浏览 3提问于2020-12-22得票数 1
consumer(reqChan chan kafkaRequest, respChan chan kafkaResponse, brokers []string) { consumer, err := sarama.NewConsumerfmt.Println("Error retri
浏览 3修改于2017-11-02得票数 1
回答已采纳
func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim
浏览 3修改于2020-05-04得票数 3
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号