回答情况：
提问时间：
问题标签：
我写了一个关于如何使用omp flush在线程之间以生产者->消费者的方式交换数据的非常简单的例子，我发现了一个有趣的行为。a: 1标志:1 TID 0生产者a: 2标志:1 TID 0生产者a: 3标志:1 TID 0生产者a: 4标志:1 TID 0生产者a: 5标志:1 TID 0
消费者a: 5标志:1计数5 TID
浏览 2修改于2011-02-26得票数 3
回答已采纳
我有一个生产者，这将是多线程。这个生产者将读取History表，以找到要选择的表和行，然后将该行添加到Kafka主题中。现在生产者需要确保将事件添加到Kafka主题中，其方式与History表登录的方式相同。因此，使用者读取它们的顺序与它在History表中记录的顺序相同，并在Postgrace上执行它。我可以将这些数据生成多个生产者。message 11 to 15messageId 1messageId 3messag
浏览 1修改于2019-01-16得票数 0
我有一个生产者-消费者模式。1个生产者(做一些工作)和7个消费者(在8核机器上)。生产者需要一次下载7个文件(总共2000个)，并等待7个线程处理它们，然后再继续下一个7个文件。ExecutorService threadPool = Executors.newFixedThreadPool(8);
int queSize = 7;Broker broker = new Broke
浏览 3修改于2013-10-31得票数 2
我一直在尝试使用Apache-Kafka在运行在virtualbox上的Arch生产者和Ubuntu VM消费者之间进行通信。通过遵循下面的youtube教程，我已经能够在一台机器上建立生产者和消费者之间的通信。 https://www.youtube.com/watch?v=VbSRS7kG5Cw 基本上，我在4个独立的终端中使用这4个命令。 ./bin/zookeeper-server-start.sh config/zookeeper.properties .，在另一个主机
浏览 20提问于2019-09-30得票数 1
我有一个生产者(PublishKafka__10处理器)和一个消费者(ConsumerKafka__10处理器)来接收来自Kafka集群的流文件。我在Nifi UI管理上看到，生产者总共收到了7个包，但消费者只收到了4个包。我还使用kafka_console_consumer.sh查看producer中的包，它显示了整个7个包。
浏览 2提问于2017-06-09得票数 1
我必须设计一个订阅者比生产者慢的系统。我不能使用任何MQ解决方案(由于预算限制)。我是否可以使用内存队列，其中生产者将把数据放入队列，而订阅者将在特定的时间间隔内轮询？如何使用Java7实现。
浏览 0提问于2017-11-30得票数 0
但问题是，当我的使用者运行时，我使用生产者将消息推送到主题，它使用该分区中的消息。但是，如果我的消费者目前没有运行，并且我将一些消息推送到主题，并再次启动消费者，它不会消费生产者推送的消息，但它再次准备消费现在将被推送的消息。例如消费者正在运行：结果:消费者将消费所有三条消息。案例2producer现在将m4，m5 m6消息推送到主题1的分区1结果:消费者不消费消息m4、m5、m6，但如果我检查偏移量，则将其设置为7。这意味着
浏览 1提问于2014-12-05得票数 1
我使用ActiveMQ 5.9.0和Java7一起使用，在我从Java7迁移到Java8之后，我的生产者程序无法创建到代理的会话。它一直在尝试获取ActiveMQSession。
浏览 2修改于2016-12-13得票数 0
回答已采纳
我正在尝试提出一种配置，它将基于生产者的平均字节率来强制生产者配额设置。我用一个3节点集群进行了测试。我用卡夫卡-生产者-perf-测试的吞吐量和油门。producer.config /myfolder/client.properties \我期望生产者客户端了解节流阀在此期间，平均延迟缓慢地增加，最后，当它达到120000 ms时，我开始看到超时异常，如下所示
配额_ org.apache.
浏览 3修改于2020-03-28得票数 2
那么这个生产者-消费者是如何运作的呢？consumed.. 4produced 5produced 7produced 8taskQueue is f
浏览 1修改于2021-08-05得票数 0
输出似乎是同步的，如下所示：PushedPushedPushedPushedPushed1357如果我将缓冲通道更改为非缓冲通道：结果似乎是异步：0Pushed2Pushed4Pushed6因此，我的场景是:在接收方中，每次从生产者接收新数据时都会发出请求，结果表明调度程序在所有数据被发送到信道(给定一个
浏览 4修改于2021-02-21得票数 0
回答已采纳
我还创建了7个KafkaConsumer(在单个group_id下，其中6个被分配给6个分区，另一个处于空闲状态(这是预期的)。当生产者正在流时，我将分区计数增加到7，期望流不会分布在7个分区上，并且会唤醒空闲的使用者。但是，在我通过重新启动应用程序重新初始化它之前，生产者似乎不会选择新添加的分区。我通过运行以下命令来缩放分区计数：是否
浏览 4提问于2017-05-18得票数 3
您好，我正在尝试使用生产者api，如Alpakka文档中所示。我可以使用事务源使用记录，生产者被创建，但不能将消息放到主题中，不能使用阿尔帕卡中的Transactional.Sink生成主题，但我看到幂等生产者已启用。我看到日志表明它正在进入逻辑，但它没有向myTopic生成事件
clientId=producer-7fe8789c-3171-429e-afbf-d8a8ba12700c，transactionalId=7fe8789c-3171-429e-afbf-d8a8ba12700c o.a.k.
浏览 3修改于2020-03-22得票数 0
最近，我开始阅读“Java7并发Cookbook”，在创建和运行守护进程线程的一节中，我找到了主线程创建的代码和ArrayDeque的一个实例，并与三个生产者和一个使用者共享了它的引用。生产者调用deque.addFirst(event)，消费者调用deque.getLast()。
浏览 3提问于2016-06-30得票数 4
生产者有一个名称(例如，“api-集成-生产者”)。当我运行这个服务的多个实例(通常在Kubernetes中)时，服务无法启动，抱怨说，名为“api-集成-生产者”的生产者已经在Pulsar broker中注册了。因此，这意味着，我不能与生成相同主题的生产者一起运行服务的多个实例，也不能对同名的生产者运行多个实例。但是，我已经通过生成一个随机的生产者名来解决这个问题(将一个uuid附加到“api-集成-生产者”)。
这对一次准确的场景有影响吗？什么是正
浏览 3修改于2022-01-13得票数 1
有一个多生产者消费者模式producer1 -> consumer 1/Producer2->consumer 2/ producer 3，每个生产者使用一个完成服务，但当它完成时，我在编写逻辑时遇到了问题问题是main把一些(x)任务放在生产者1队列上，这反过来会导致生产者1把(y)任务放在生产者2上，生产者2会把z任务放在生产者3上。x，y和z是不同的，所以main不能只看生产者3的完成队列并获取z的未来，因为mai
浏览 6提问于2011-11-15得票数 1
回答已采纳
理论上，这对生产者和消费者来说都应该是相对无缝的。但是，当测试代理停机超过5分钟时，我们在生产者应用程序上得到了这些错误： -Expiring 7 record(s) for topic2-0: 30033 ms has passed since last append ERROR - 2019此时，长期运行的生产者变得没有响应能力，每个生产者的请
浏览 0修改于2019-02-27得票数 2
回答已采纳
我正在编写一个具有多生产者、单消费者模型的应用程序(多线程将消息发送到单个文件写入器线程)。在消费者线程的循环中，它在处理完所有生产者线程后休眠一段指定的时间。我立即注意到的一件事是，当我从1个生产者线程转移到2个生产者线程时，生产者将一些东西写入队列并
浏览 4提问于2009-09-09得票数 2
回答已采纳
3回答
Germany: [], Greece: [], isLoading: false "_id" : ObjectId("5cc0bf1815cc7a2225edab0b"), "URL" : "/jSQcl: "",
浏览 12修改于2019-05-03得票数 3
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号