回答情况：
提问时间：
问题标签：
我们编写了一个java生产者客户机，它的代码如图所示properties.put("metadata.broker.list
浏览 5修改于2017-05-23得票数 1
回答已采纳
我用symfony 3创建了一个制片人class ProducerController extends Controller* @Route("/_load (module.js:424:3)at run (bootstrap_node.js:394:7)at bootstrap_node.js:509:3
浏览 1修改于2017-02-13得票数 1
回答已采纳
问题是main把一些(x)任务放在生产者1队列上，这反过来会导致生产者1把(y)任务放在生产者2上，生产者2会把z任务放在生产者3上。x，y和z是不同的，所以main不能只看生产者3的完成队列并获取z的未来，因为main不知道z。所以我尝试了毒丸的想法和一个初始化为3的CountDownLatch，main知道生产者1只有x个任务，所以我可以在最后提交一个毒丸，然后当生产者1收到这个时，它可以递减闩
浏览 6提问于2011-11-15得票数 1
回答已采纳
我在C中处理生产者消费者问题，但是当与producer并行时，使用者线程不会运行。/a.out 3 4 3，即n=3，pro = 4，con =3时生产者2生产者1生产者0消费者0消费者1生产者0退出:生产者消费者0退出:消费者当我给出像./a.out 4 4 3<
浏览 0修改于2018-02-05得票数 3
回答已采纳
假设我有两个生产者(ProducerA和ProducerB)使用单个分区写入相同的主题。每个生产者都在连续编写自己独特的事件。所以如果ProducerA触发了3个事件，然后ProducerB触发了3个事件，我的理解是Kafka不能保证生产者事件的顺序如下：由于打包、
浏览 25提问于2018-08-29得票数 5
回答已采纳
我有以下实体:生产者，消费者。举个例子，我有生产者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
每个生产者都推送邮件ids，然后使用者获取ids并将邮件插入到db。当我们有100个消费者(例如)而生产者生成In的速度太快时，每个消费者都会获得In并使用api获取邮件，因此并发请求对api的限制将是例外。С和我们限制每个生产者的使用者(例如，如果最大的3个消费者将接收一个生产者的if，那么下一个3将从另一个生产者接收，等等)？
浏览 2修改于2016-04-06得票数 0
我有一个非常奇怪的问题，我在Scala中实现了一个Kafka生产者客户端，当Kafka集群启动时，一切都正常工作。也就是说，生产者将数据正确推送到Kafka中。然而，如果我设置我的生产者是‘异步’，Kafka生产者客户端将正确地放置数据，如果集群启动和工作，但生产者也推送数据into...the无效...如果集群关闭了！也就是说，如果集群宕机，Kafka生产者不会返回错误。
这对我来说是一个担忧，因为当生产者找到要推送到Kafka中的数据时，它会删除data...so的
浏览 2提问于2014-10-29得票数 0
我们有两层代码，第一层是消费者，另一层是生产者。2)。消费者正在调用生产者，因为生产者有许多微服务。3)。在调用过程中，Producer正在生成唯一的ID以用于事务跟踪。4)。我们可以直接调用生产者，它将生成结果集。5)。在生产者调用期间，我们必须在来自POSTMAN的标题中添加唯一的日志事务ID。现在的问题是，如果想要直接命中生产者，并且不想传递日志事务ID，有没有办法让我的生产者路由器理解头部中没有LOGTRANSACTION，它将生成一个名为&q
浏览 21提问于2019-06-12得票数 0
我希望写一个生产者，可以保留消息在卡夫卡每16秒，并在刷新所有的消息到主题。有可能做到吗？我使用的是Kafka python。这个想法是:我有100条消息，在正常行为下，生产者会这样做： 生产者:消息1消息2消息3...消息100 消费者:消息1消息2消息3...消息100 我想这样做:生产者:消息1消息2消息3 ...消息100消费者:消息1消息2消息3... 16s之后 ...message N-1消息N 16s之后 消息100 有没有可能只使用K
浏览 12修改于2020-11-22得票数 2
我经常使用(多)生产者-队列-消费者设计模式，但我不知道如何获得操作的结果。使用者C如何告诉生产者(P1、P2或P3)请求已完成并给出结果？
浏览 2提问于2013-02-05得票数 0
回答已采纳
我有3台服务器，它们之间有10 in的连接，在2台服务器上运行Kafka集群，并在第三台服务器上生成一些测试…那么为什么会发生这个问题，我该如何解决这个问题(我希望两个生产者都花3秒的时间)？
浏览 0提问于2017-10-22得票数 0
使用spring模板，我有两个不同的生产者，它们以相同的键发送不同的消息给主题，总是以相同的形式：生产者2:发送密钥:2消息: def卡夫卡保证不同的制作者用相同的键发送的信息将被发送到相同的分区。但是，当从生产者1分配分区时，生产者2用相同的键将消息发送给不同的分区。我已经看到了有关这方面的信息，但是没
浏览 1修改于2019-05-17得票数 0
回答已采纳
我有一个带有生产者和产品表的数据库，我正在试图找到平均价格最高的产品的生产者。基本上，我要找出每个生产者的平均水平，然后找出平均价格最高的生产者，如果他们有相同的平均水平，就可以有多个生产者拥有最昂贵的平均水平。WHERE MAX(average) 1 | 103| 10
4
浏览 5修改于2015-04-12得票数 0
回答已采纳
我得到了和的示例代码，Q2。这是一个关于在多生产者环境中的一般性问题，一个生产者的结果如何与环形缓冲区中的前一个生产者的结果相互关联。
例如: Is Disruptor可用于单个文件/变量由多个生产者更新的环境中。也就是说，有两个生产者(P1，P2)，它们更新一个共享变量(命名为“count”)。(这里count是ValueEvent类中的一
浏览 0修改于2013-01-24得票数 0
4回答
有没有人知道是否有一种可靠的方法来设置生产者-消费者类型的队列，其中满足以下条件：2)消费者消费一件物品，留下两个对象在队列中4)消费者又消费了一件商品，循环因此继续
请注意，我需要手动设置解决方案，而不是为我正在处理的作业使用任何接口。
浏览 0修改于2012-11-24得票数 0
我想要创建一个生产者/消费者与经理程序在Go。例如:我有一个5 producers, 5 consumers and manager。Manager拥有own array，它存储有哪些元素和有多少个元素(例如--如果生产者发送1 1 2 3 1 2 0元素，管理器数组看起来就像1 3 2 1 ( 1 0、3 1、2 2和1 3)，它处理生产者和消费者的请求我已经在JAVA + CSP中这样做了，它提供了发送信息的通道，并在管理器中进行保护，以确定当生产
浏览 2修改于2013-12-24得票数 1
回答已采纳
我已经设置了春天云流卡夫卡生产者和消费者和有3卡夫卡经纪人运行。我已经将min.insync.replicas设置为4，以了解生产者错误处理是如何工作的。messagechannel.send调用立即返回，生产者日志继续表示NOT_ENOUGH_REPLICAS，这是很好的，也是预期的。true bindings: producer:s
浏览 11修改于2022-05-10得票数 1
回答已采纳
c1:case c2 <- i2:case i3,ok := (<-c3): // same as: i3, ok := <-c3 print("received ", i3
浏览 5修改于2017-05-23得票数 12
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号