回答情况：
提问时间：
问题标签：
我正在尝试将Dagger 2与eclipse集成，我使用的库如下所示：dagger-compiler-2.0.jarjavawriter
浏览 1提问于2015-10-01得票数 2
回答已采纳
我正在尝试使用WSO2企业服务总线消息生成器在此队列中生成消息。下面是我的制作人的来源。Unexpected error during sending message out at org.apache.axis2.engine.AxisEngine.send(AxisEngine.java:442)
at org.apache.axis2client.Operation
浏览 1提问于2013-09-20得票数 0
我已经在两个集群(CL1，CL2)上设置了一个mirrormaker2，镜像似乎工作正常，除了以下场景中测试主题中的重复项问题：问题开始于重新启动代理。在启动第一个代理之后，我注意到一些消息(大约5%)是重复的。在下面
浏览 37提问于2021-03-09得票数 1
3个消费者2个生产者。对一个缓冲区进行读写操作。生产者A将1个元素推送到buffer (长度N)，而生产者B正在将2个元素推送到buffer。无活动等待。我不能使用System V信号量。生产者A的示例代码： while(1){ sem_wait(mutex);
我还尝试为生产者B设
浏览 1修改于2016-12-04得票数 0
我正在尝试将“如何使WSO2 API能够作为生产者工作”这篇文章中描述的两种模式进行原型化。我有以下问题和问题: 1.在“模式1: JMS管理器作为WSO2消费者”中的步骤3创建中介时，我会遇到异常。当在参考资料选项卡中选择‘Browse’图标时，我得到了带有以下错误的空白屏幕。
浏览 4修改于2016-01-22得票数 0
我是一个编写Java的新手，目前我正在尝试实现经典的“生产者-消费者”问题的另一个方面。我仍然像往常一样使用一个生产者，它在缓冲区中写入字符串。这个缓冲区是与2个Consumer线程共享的，我要做的是让这两个Consumer线程拾取生产者发送的每个字符串，然后才从缓冲区中删除该字符串。如何检查两个消费者线程是否都已获取该字符串？谢谢!
浏览 21提问于2018-12-13得票数 1
回答已采纳
我想使用rxjava2实现简单的生产者-消费者模型，当下游请求一个，上游发出一个。 .observeOn(Schedulers.computation(), false, 1) //=====> 2public void onComplete() {
});
实际
浏览 5提问于2017-12-01得票数 0
回答已采纳
这是一个简单的、普通的Kafka应用程序，它执行使用EXACTLY_ONCE_V2配置的简单记录转换。configurationParameters.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE_V2)如果删除上面提到的EXACTLY_ONCE_V2设置，此错误将消失，流应用程序将运行数天而不会出现错误。错误日志是：
错误2021-11-27 18:10:23.141卡夫卡-生产者-网络线程id-mapping-app-
浏览 29修改于2021-11-28得票数 5
回答已采纳
有一个多生产者消费者模式producer1 -> consumer 1/Producer2->consumer 2/ producer 3，每个生产者使用一个完成服务，但当它完成时，我在编写逻辑时遇到了问题问题是main把一些(x)任务放在生产者1队列上，这反过来会导致生产者1把(y)任务放在生产者2上，生产者2会把z任务放在生产者3上。x，y和z是不同的，所以mai
浏览 6提问于2011-11-15得票数 1
回答已采纳
Thread c1 = new Thread(new Consumer(monitor), "C-odd"); Thread c2(c1); for (Thread thread : threads) { Thread c1 = new Thread(new Consumer(monitor), &
浏览 2修改于2017-03-29得票数 0
回答已采纳
使用spring模板，我有两个不同的生产者，它们以相同的键发送不同的消息给主题，总是以相同的形式：生产者2:发送密钥:2消息: def卡夫卡保证不同的制作者用相同的键发送的信息将被发送到相同的分区。但是，当从生产者1分配分区时，生产者2用相同的键将消息
浏览 1修改于2019-05-17得票数 0
回答已采纳
通过allowNonTransactional属性，可以使用相同的KafkaTemplate创建事务性和非事务性生产者。两个生产者类型都将使用来自KafkaProducerFactory的相同配置。在某些特定情况下，可能需要对这2种生产者使用不同的配置。下面的示例显示了一个具体的用例问题可以通过有2个工厂和&#x
浏览 9提问于2022-01-13得票数 0
我有以下实体:生产者，消费者。举个例子，我有生产者p1，p2，p3和消费者c1，c2，c3。c1 c2 c3p2 Y N N记住
消费者和生产者的数量将继续增长。
浏览 0提问于2018-02-09得票数 0
我有以下实体:生产者，消费者。举个例子，我有生产者p1，p2，p3和消费者c1，c2，c3。c1 c2 c3p2 Y N N记住
消费者和生产者的数量将继续增长。消费
浏览 0提问于2018-02-08得票数 1
我得到了和的示例代码，Q2。这是一个关于在多生产者环境中的一般性问题，一个生产者的结果如何与环形缓冲区中的前一个生产者的结果相互关联。
例如: Is Disruptor可用于单个文件/变量由多个生产者更新的环境中。也就是说，有两个生产者(P1，P2)，它们更新一个共享变量(命名为“count”)。(这里count是Value
浏览 0修改于2013-01-24得票数 0
我们有两层代码，第一层是消费者，另一层是生产者。2)。消费者正在调用生产者，因为生产者有许多微服务。3)。在调用过程中，Producer正在生成唯一的ID以用于事务跟踪。4)。我们可以直接调用生产者，它将生成结果集。5)。在生产者调用期间，我们必须在来自POSTMAN的标题中添加唯一的日志事务ID。现在的问题是，如果想要直接命中生产者，并且不想传递日志事务ID，有没有办法让我的生产者路由器理解头部中没有LOGTRANSACTION，它将生成一个名为&q
浏览 21提问于2019-06-12得票数 0
假设我有两个生产者(ProducerA和ProducerB)使用单个分区写入相同的主题。每个生产者都在连续编写自己独特的事件。所以如果ProducerA触发了3个事件，然后ProducerB触发了3个事件，我的理解是Kafka不能保证生产者事件的顺序如下：由于打包、重试等原因。例如：
Producer
浏览 25提问于2018-08-29得票数 5
回答已采纳
生产者填充缓冲区#1，然后填充缓冲区#2。使用者每次消耗一个缓冲区，速度非常慢。当它正在消耗缓冲区#1时，生产者已经准备好填充另一个缓冲区，但是它们都已经满了，并且使用者还没有完成第1缓冲区。所以，生产者等待。
我希望生产者更新“免费”缓冲区，而不是等待。也就是说，当使用者使用缓冲区#1时，生产者应该在缓冲区#2上写入新数据(“旧”数据被覆盖和丢失)。如果消费者还没有完成#1，而生产者有更多的数据要写，它应该再次写在#2上，以此类推。
浏览 3提问于2009-06-04得票数 0
回答已采纳
我正在编写一个具有多生产者、单消费者模型的应用程序(多线程将消息发送到单个文件写入器线程)。在消费者线程的循环中，它在处理完所有生产者线程后休眠一段指定的时间。我立即注意到的一件事是，当我从1个生产者线程转移到2个生产者线程时，生产者将
浏览 4提问于2009-09-09得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号