1回答
我正在尝试使用ReentrantLock实现一个包含仓库、消费者和制造商的程序。我有一个基于数组的循环队列作为商品的存储。生产者最多可以生产n次产品。我面临的问题是消费者没有参与到这个过程中来。你能告诉我我哪里弄错了吗？p.sleep(2000); catch (InterruptedException e){} }
浏览 8提问于2020-05-02得票数 0
我有一台电脑，目前托管的是zookeeper和kafka服务器。我已经成功地构建并运行了一个运行消费者脚本的容器，但它将永远等待kafka消息。
如何将kafka消息重定向到容器中？唯一的方法是直接在容器中
浏览 17提问于2020-02-21得票数 0
回答已采纳
我需要使用使用Java和Spring框架的生产者-消费者模式来解决问题。问题是我是Spring框架中的新手(我不知道)，所以有人能指导我如何使用Spring来实现这个目标吗？一些书或网站，我可以找到一个例子，一步一步地实施生产者-消费者模式与Spring？
浏览 0提问于2016-02-05得票数 2
我尝试在我的应用程序中使用ActiveMQ 5.8.0消息组，但在阅读文档后没有得到预期的结果。
我为特定队列启动两个(或更多)使用者，然后将消息发送到该队列。请注意，出于测试目的，我对"foo“进行了硬编码。它最终将是一个由生产者设置的字符串。由于我的消息中只设置了一个消息组，因此我希望看到一个使用者将变为活动状态并使用队列中的所有消息，而另一个使用者将保持静止。相反，我看到第一个消息由
浏览 3提问于2013-06-04得票数 2
我准备了easyScoreCalculatorClass和incrementalScoreCalculatorClass (Java记分)的例子来解决电力消费者和电力供应商的问题(电话和充电器，其中电压必须相等，消费者要求的安培不得大于供应商提供的安培，每个供应商都有成本)。Optaplanner为具有两个消费者和一个供应商的样本制定解决方案，这并不是我所期望<e
浏览 0提问于2015-02-16得票数 1
我正在运行一个多线程卡夫卡091消费者新。
我生成client.id的方式是使用“使用者在”+ "AtomicInt“+”进程PID“上运行的主机名的组合。当我必须停止使用者并重新启动时，我遇到了问题。使用者一直在尝试处理上一次运行中没有使用的偏移量(其中大约有100次)。但这条信息一直在失败。从卡克法的日志中，我看到了许多再平衡的发生。
浏览 1提问于2016-10-21得票数 0
回答已采纳
我在spring boot应用程序的消费者接收器上使用@SendTo注释，没有参数。收到的消息包含头部"Kafka_replyTopic"，但@SendTo无法读取，kafka在发送回复时抛出异常： Listener failed; nested exception is java.lang.IllegalStateException
浏览 64提问于2020-09-02得票数 0
回答已采纳
问题所在
嗨，我试着用Grafana来想象卡夫卡的滞后。我一直在尝试记录卡夫卡的滞后使用米特里贝特，并自己做的数学，因为米特里拍不支持日志卡夫卡滞后的版本，我正在使用()。我不是使用max(partition.offset.newest) - max(consumergroup.offset)来计算延迟，而是在特定的kafka.topic.name上使用过滤过的sum(partition.offse
浏览 1提问于2019-12-10得票数 0
我已经使用现有的WSDL创建了一个体验API，在此之前我正在执行几个步骤：
</env:Body>
根据；这需要在流程开始时执行额外的转换步骤传递SOAP主体不是问题<
浏览 1提问于2020-08-20得票数 0
回答已采纳
我正在尝试做一个简单的poc与spring kafka与spring boot与版本(2.3.7版本)，以实现如何消费者批处理工作，以及如何重新平衡工作，如果消费者需要更多的处理时间，因为我对这个消息传递系统完全陌生现在我看到了kafka与单一消费者(不允许并发)重新平衡的问题。这些是我设置了
浏览 98提问于2021-02-01得票数 1
我刚开始使用颤振编程，我遇到了一个问题，要导航到一个新页面并让onPressed正确工作。我正在使用下面的代码片段，并且我已经看到其他教程视频也做了同样的事情，但是当我使用代码片段--所有来自"() { Navigator.push( . )；}“--用红色加下划线时，都会出现错误：
我不知道如何修复这个错误，任何帮助都将不胜感激，谢谢。
浏览 2提问于2022-02-18得票数 0
回答已采纳
1回答
目前，我有三个卡夫卡经纪人与150个分区。我还有3个消费者，每个消费者被分配给一组分区。每个消费者都有自己的本地国家商店与rocksdb。这个内存中的键值存储是在grpc调用期间调用的.在再平衡期间(如果消费者消失了)，数据将被写入到其他使用者的本地存储中。
如果消费者运行了大约2周，那么这些服务似乎没有内存了。是否有办法解决当地仓库增长过快<e
浏览 3提问于2019-12-10得票数 1
回答已采纳
2回答
我有一个生产者和一个消费者。生产者用对象填充其内部队列，消费者一个接一个地获取这些对象。我想让消费者与生产者同步，这样消费者就会在没有准备好的对象时阻塞，我想让生产者与自己同步，这样当队列满了时它就会停止生产(当有空间时，它会重新开始)。我该怎么做？我可以使用NSConditionalLock在没有队列的情况下解决更简单的情况，
浏览 3提问于2010-10-09得票数 0
回答已采纳
1回答
多人游戏的匹配
、、、
我的工作代码需要对可伸缩性和整体性能进行一些优化。这段代码基本上创建了一个大厅，用户等待创建匹配，并链接用户进行多人游戏比赛。多人会话用于保存这两个玩家的数据。我相信定时器是一个单独的线程，它运行在后台，而请求也被保存在服务器上。此外，当用户等待匹配时，每0.1秒调用一次Thread.sleep。有什么更好的方法来实现/优化这一点吗？这里应该存在一个可伸缩性问题。
我认为整体表现迅速上升，因
浏览 0提问于2018-05-22得票数 3
1回答
我将模拟生成日志的过程称为“生产者”，将另一个将日志格式化为“消费者”的过程称为“消费者”。假设我有大量可用内存，那么生产者和消费者沟通的最佳方法是什么？
此时，每个生产者可以生成高达100 logs的日志。因此
浏览 1提问于2018-06-30得票数 0
我们有两个不同的数据中心DC1和DC2。DC1是主动的，DC2是被动的。现在，我们已经在DC1中安装了Apache，并创建了主题，编写了生产者和消费者的文章，并且能够正确地将数据从源推送到接收器。我们需要保持DC2的接收器与DC1同步。这意味着由生产者推送到主题A的数据需要由两个消费者消费。已经在工作的第一个消费者来自DC1本身，而另一个消费者必须来自DC2。我们想出一个这样<em
浏览 0提问于2016-11-11得票数 1
回答已采纳
这个数字各不相同，我不确定这是输出问题还是它们真的不在那里。这也让我感到困惑，因为当我最初启动(所有新的Kafka和消费者部署)时，这不会发生。因此，这似乎真的与消费者部署被扩展或被扼杀有关。然后，在很短的时间内，分配给消费者，大约半分钟后，上面的相同图片再次显示了消费者组正在重新平衡的位置。
当我缩小规模时，也会发生这种情况。例如，当我只有4个消费者时。我不确定
浏览 0提问于2020-10-02得票数 0
我的web应用程序是一个谷歌OpenID消费者(带有属性交换和OAuth扩展)，我需要为它的编辑编写一些单元测试:测试负责与谷歌交互的单元。问题是默认的OpenID登录过程需要用户交互(输入用户/密码)，而这在单元测试中是不可能的。
你知道我如何解决这个问题并对我的OpenID消费者
浏览 0提问于2011-02-24得票数 3
回答已采纳
1回答
根据，对于标准队列，飞行中消息的最大数量设置为120,000。然而，有时我看到我的队列在较小的数字下变得最大，例如：
有人知道为什么会这样吗？我的代码可以根据队列中的消息数量动态地更改SQS侦听器的数量，但是如果达到了最大值，我就不想做任何事情。我现在的问题是，最大限制似乎不一致。有些队列达到了120K，但这个队列却停留在100K，而且据我所知，没有任何设置允许我</
浏览 3提问于2018-03-30得票数 0
我试图用Kafka实现一个发布-订阅模型，其中一个主题将被许多独立的消费者阅读/消费。
根据我的理解，每个使用者都通过使用唯一的group.id将自身标识为唯一的订阅者。然而，如果消费者B用与消费者A相同的group.id来宣传消费者A的消息，那么恶意或错误的消费者B就可以给消费者A的消息提供钢材，从
浏览 0提问于2018-10-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
