回答情况：
提问时间：
问题标签：
我有一个生产者/消费者模式，如下所示每个生产者都在运行数据库查询，并将结果写入其队列消费者调查所有的生产者队列。目前，如果存在数据库错误，生产者线程就会死掉，然后消费者就会永远被困在产品队列上等待更多的结果。
我应该如何构造这个以正确处理捕获错误？
浏览 5提问于2012-05-04得票数 1
我有一个生产者和一个消费者。生产者用对象填充其内部队列，消费者一个接一个地获取这些对象。我想让消费者与生产者同步，这样消费者就会在没有准备好的对象时阻塞，我想让生产者与自己同步，这样当队列满了时它就会停止生产(当有空间时，它会重新开始)。我该怎么做？
浏览 3提问于2010-10-09得票数 0
回答已采纳
生产者有一个名称(例如，“api-集成-生产者”)。当我运行这个服务的多个实例(通常在Kubernetes中)时，服务无法启动，抱怨说，名为“api-集成-生产者”的生产者已经在Pulsar broker中注册了。因此，这意味着，我不能与生成相同主题的生产者一起运行服务的多个实例，也不能对同名的生产者运行多个实例。但是，我已经通过生成一个随机的生产者名来解决这个问题(将一个uuid附加到“api-集成-生产者”)。
这对一次准确的场景有影响吗？什么是正
浏览 3修改于2022-01-13得票数 1
我正在设计一个系统，其中将有n生产者和m消费者，其中n和m是数字，n != m。
我不知道我应该用什么数据结构和算法来实现这个系统。
有人能在这方面给我提供帮助/指点吗？
浏览 5提问于2015-04-30得票数 4
我正在尝试将Dagger 2与eclipse集成，我使用的库如下所示：dagger-compiler-2.0.jarjavawriter-1.0.5.jarjavax.inject-1.jar但是，在构建项目时会出现以下错误: Description Resource Type
Internal compiler error: java.lang.NoClassDefFoundError: da
浏览 1提问于2015-10-01得票数 2
回答已采纳
1回答
棘手的是，传出的主题可能还不存在，我需要有机会根据环境变量的要求关闭生产者。UNKNOWN_TOPIC_OR_PARTITION 尝试了不同的生产者属性，但没有成功。我还尝试使用ConditionalOnProperty注释生产者类，但服务类需要该bean。
浏览 35修改于2021-11-15得票数 0
如何在所有生产者之间实现幂等？我的意思是，如果'equal‘消息将被发送给Kafka和不同的生产者，那么它将只在日志中提交一次。
浏览 6修改于2019-10-12得票数 1
回答已采纳
因此，我们有一个“生产者”进程，它将每个记录ID发送到消息队列(SQS)。这种模式效果很好。然而，数据量继续增长。我们的单个生产者不再能够跟上插入到表中的数据量。is_queued tinyint(1)updated_at timestamp我希望有多个
浏览 0修改于2018-04-30得票数 0
回答已采纳
2回答
有没有办法从Kafka集群中收集Kafka生产者配置？我知道这些设置存储在客户端本身。我至少对client.id和生产者要发布到的主题集合感兴趣。
浏览 6修改于2020-05-27得票数 0
如果设置了Kafka生产者压缩(例如，设置为gzip)，并且broker配置也被设置为相同的编解码器，那么broker是否会重新压缩来自生产者的任何消息，或者识别它是相同的编解码器并跳过和代理端重压缩我知道可以将代理配置为通过“生产者”设置继承代理编解码器。然而，对于我们的场景，我们可能有生产者(在我们的控制之外)，他们可能不会设置任何压缩，所以我们希望将代理配置为启用默认压缩，但对于那些在我们控制之下的生产者，我们更喜欢使用生产者压缩来节省网络带宽，同时也减少代理上的负载
浏览 25修改于2019-07-04得票数 3
我有一个消费者作为生产者消费模式的一部分：public class MessageFileLogger : ILogger private BlockingCollection<ILogItem
浏览 2修改于2014-02-26得票数 1
回答已采纳
我正在尝试使用Kafka的生产者和消费者来创建一个转换，在Pentaho数据集成中。有没有适用于Apache Kafka生产者和消费者的例子？或者你能让我知道如何创建转换吗？
浏览 4修改于2015-01-26得票数 0
我对生产者消费者食谱将如何与Zookeeper合作几乎没有疑问。拥有不同的生产者和消费者实例意味着没有任何本地锁(同音化)会有任何用处。
浏览 4提问于2013-05-12得票数 0
回答已采纳
1回答
通过设置batch.size，我们告诉生产者对记录进行批处理，直到记录的大小达到该限制，然后发送它们。有一个奇怪的配置linger.ms，它说如果生产者想要发送记录，但batch.size没有到达等待更多。
我的问题是，生产者如何可能在记录的大小到达batch.size之前发送记录？
浏览 18修改于2018-01-02得票数 0
回答已采纳
3回答
我在我的本地主机上设置了Kafka，并试图监控Kafka生产者的行为，以防出现网络问题。
即使当所有代理都关闭时，生产者也不会给出任何错误。我使用的是同步制作器和Kafka 0.8版。如果所有的代理都宕机了，生产者有没有办法收到异常？
浏览 0提问于2015-10-16得票数 0
生产者填充缓冲区#1，然后填充缓冲区#2。使用者每次消耗一个缓冲区，速度非常慢。当它正在消耗缓冲区#1时，生产者已经准备好填充另一个缓冲区，但是它们都已经满了，并且使用者还没有完成第1缓冲区。所以，生产者等待。
我希望生产者更新“免费”缓冲区，而不是等待。也就是说，当使用者使用缓冲区#1时，生产者应该在缓冲区#2上写入新数据(“旧”数据被覆盖和丢失)。如果消费者还没有完成#1，而生产者有更多的数据要写，它应该再次写在#2上，以此类推。当使用者最终使用#1中的所有数据时，它应该立即开始使用
浏览 3提问于2009-06-04得票数 0
回答已采纳
3个消费者2个生产者。对一个缓冲区进行读写操作。生产者A将1个元素推送到buffer (长度N)，而生产者B正在将2个元素推送到buffer。无活动等待。我不能使用System V信号量。生产者A的示例代码： while(1){ sem_wait(mutex);
我还尝试为生产者B设置一个不同的信号量，当缓冲区中有2个
浏览 1修改于2016-12-04得票数 0
2回答
但是，我为EntityManager定义了一个生产者，因此：public class Resources {
@PersistenceContext(unitName
浏览 2修改于2013-07-25得票数 2
回答已采纳
2回答
这是必须使用特定于每个代理的server.properties为每个代理设置的内容，还是必须由生产者设置的内容？如果必须由生产者设置，请解释如何使用Java API进行设置。
浏览 0修改于2021-07-18得票数 13
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号