当我产生一条消息时，我正在使用Go中编写的Sarama库从错误通道读取。整个代码如下所示，它包含在一个函数中：go func() {
for err := range sarama
浏览 5提问于2018-02-01得票数 0
回答已采纳
3回答
我有一个实现“Runnable”来从数据流中读取数据的类。数据来自一个Channel，它作为成员变量存储在我的另一个类中，我只需调用getter getInputChannel()就可以得到这个通道的一个实例。现在，为了让我的Runnable从通道读取数据，它需要知道它是什么类型的</
浏览 7提问于2013-11-12得票数 0
回答已采纳
kafka版本: 1.0.0 sarama版本: 1.15.0 go版本: 1.9.1func main() { log.Println(err) } counter := 0
}
从日志中我发现有65
浏览 2提问于2018-02-05得票数 1
回答已采纳
1回答
原始代码可以找到
原始包实现了一个PartitionConsumer，如果您不需要使用相同主题的多个使用者之间的读取一致性，那么它就能很好地工作，但是，这对我不起作用。我在同一个应用程序中做了一些工作，使用我在网上找到的一些例子来实现sarama NewConsumerGroup包。当我运行这个程序时，使用者启动并使用正确的组读取正确的主题，并使用在此函数中创建的
浏览 3提问于2019-12-24得票数 2
回答已采纳
1回答
背景{uuid: 123状态: 1}状态1表示开始我使用sarama.NewConsumerGroup问题我发现通道msgQueue中的消息顺序不是固定的。
那么，如何确保数据的最终状态是3？当数据顺序为{
浏览 1提问于2021-10-25得票数 1
1回答
我来这里是为了找出最惯用的方法来完成以下任务。将数据从通道写入文件。我有一个ch := make(chan int, 100)频道
如果频道ch没有满，每5s写一次。因此，从本质上说，数据需要至少每
浏览 0提问于2016-07-18得票数 1
回答已采纳
我想读取HttpResponse中包含的ChannelBuffer对象中存储的二进制数据。我试着用下面的代码从ChannelBuffer中读取并保存，但它不起作用。读取存储在通道缓冲区中的二进制数据的正确方法是什么？不确定从ChannelBuffer复制字节
浏览 0提问于2013-05-20得票数 0
回答已采纳
我正在处理从多通道电极系统收集的数据，并试图使其运行得比现在更快，但我找不到任何没有循环的好方法。
它的要点是；我已经修改了每列(这是一个通道)的平均值，并且需要将列中的每个值与该列的平均值进行比较。如果该值高于调整后的平均值，则需要将该值放入另一个数据框中，以便可以轻松读取。to run it multipl
浏览 1提问于2017-08-08得票数 1
回答已采纳
1回答
我们从Enobio8设备读取数据，并在记录文件时读取数据。该文件与.easy文件一起保存为.info格式。
MNE是正确使用的库，还是有其他库可以处理这些类型的文件？当我试图通过使用mne.io.read_raw_edf读取脑电图文件时，我应该包括很多参数，比如蒙太奇(更多信息请参考 )，如何创建这些参数，如蒙太奇、eog和misc？蒙太奇文件应该
浏览 4提问于2017-05-10得票数 1
这个方法的简单地说：
创建一个允许从通道读取所有数据的IAsyncEnumerable。返回的可枚举值是在调用时表示通道的快照，还是在我枚举时其他参与者添加/删除项时，通道的“实时”视图将正确运行？
浏览 0提问于2020-05-20得票数 0
回答已采纳
我有一个库，它只公开流数据上的阻塞theRead函数。现在我需要theRead数据并在GTK3 GUI中显示。因此，我使用事务通道将数据从运行theRead的线程传递给GUI线程，然后通过g_idle_add读取var。显然这是不对的。应用程序导致CPU繁忙。正确的方法是什么？
浏览 0提问于2018-09-21得票数 2
回答已采纳
2回答
我正在学习频道如何在围棋中工作，并偶然发现了关闭频道的问题。这是Go之旅的一个修改示例，它生成n-1斐波纳契数并通过通道发送，留下通道容量的最后一个“元素”未使用。当我不关闭频道的时候。究竟是什么导致了僵局？当我不关闭频道的时候，为什么我不能从它的容量边界接收它呢？
浏览 2提问于2016-04-17得票数 0
回答已采纳
我搞不懂为什么Flume数据在使用文件通道时是可恢复的，而在使用内存通道时是不可恢复的。
我尝试了Kafka接收器，当我在阅读时放下Flume时，Kafka正确地读取了通道中的数据(文件)。重新启动Flume后，管道将继续以可靠的方式传送数据。那么为什么内存通道是不可恢复的呢？在这种情况下，我需要恢复通道<em
浏览 0提问于2017-08-03得票数 0
我有一个要求，我必须从sql server本地数据库读取数据，并首先将其映射到由另一个第三方组织提供的XML文件中。他们有自己的数据库。到目前为止，我能够连接sqlserver数据库在mirthconnect，但是我不知道需要在通道和转换器中创建哪些步骤来承载读取数据和将相应字段映射到第三方提供的XML格式的任务，最后写入提供<
浏览 2提问于2012-08-10得票数 2
因此，我试图将Kafka用于我的应用程序，该应用程序有一个生产者将操作记录到Kafka MQ中，而使用者将它从我的应用程序在Go中的MQ.Since中读取出来，我正在使用Shopify Sarama来实现这一点现在，我能够读取MQ并使用但是，我真的希望错误处理比控制台打印更好，我愿意多走一步。我可以想到的错误条件是，msgContent实际上并不包含JSON中的</e
浏览 0提问于2015-04-01得票数 3
回答已采纳
1回答
我的代码如下所示：... ...我有一个生产者正在向outChannel写入数据，并希望在读取时超时(如果整体处理时间超过XX秒)。这样做的正确方式是什么？
但是，由于我只见过使用select和多个case从通道读取的构造(at：)，所以在使用range时，这似乎不适用。
浏览 0提问于2016-09-20得票数 2
回答已采纳
我在这里使用HTTP作为我的示例(我知道库中有HTTP (de/en)编码器，但对我来说，这个练习的重点是让我了解管道是如何工作的。)); }播音器是一个具有MessageToByteEncoder<String>方法的= msg.getBytes(CharsetUtil.US_ASCII);}
源是一个具有Chan
浏览 0提问于2018-10-17得票数 0
回答已采纳
1回答
我有一个应用程序，从数据库读取使用NHibernate Dal的xml。dal调用存储过程来读取模式中的数据并将其封装到xml消息中，将其包装成消息，并将其排队到内部队列中进行处理。我想保护从数据库读取到出队操作的通道。最好的方法是什么？我正在考虑使用System.Security.Cryptography.X
浏览 2提问于2010-05-10得票数 0
回答已采纳
我想从两个音频文件中读取数据，并在混合之后将其写入一个新的音频文件。两个音频都有相同的持续时间，采样和频道数，我想用audio1的左通道和audio2的右通道来做立体声输出。根据我在MediaTool API演示中可以看到的内容，每当数据包被读取和解码时，都会调用onAudioSamples，但是对于这个场景，在调用onAudioSamples时，需要有audio
浏览 2提问于2012-04-16得票数 1
3回答
Go -如何知道输出通道何时完成
、、、、
我试着效仿Rob Pike在演讲“并发不是并行”中的例子，做了这样的事情:我作为工作者启动了许多go例程，这些例程从输入通道读取数据，执行一些处理，然后通过输出通道发送结果。然后，我启动另一个go例程，该例程从某个源读取数据，并通过工人的输入通道将其发送给工人。最后，我希望迭代输出通道中的所有结果，并对它们执行
浏览 6提问于2014-12-22得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
