回答情况：
提问时间：
问题标签：
比方说，我有一个有两个分区的主题-- P1，P2，以及消费者组CG1中的两个消费者C1，C2。现在，每个使用者都在使用来自一个分区的消息。现在这两个消费者都因为某种原因而死了。在这种情况下，
如何查看此使用者组的每个分区的偏移量详细信息？
浏览 2提问于2020-01-06得票数 3
回答已采纳
因此，很明显，当使用API1.0时，您需要从OAuth提供者处获取消费者密钥和消费者机密……
但是，当我尝试使用Facebook、Google OAuth 2.0等Facebook 2.0API时，我从来不需要获取消费者密钥/消费者机密(我为Oauth获取了应用程序ID和应用机密，但它们与消费者密钥/消费者机密不同，我说的对吗？)因此，我的问题是，在使用OAuth2.0时，不需要像在OAuth1.0中那样拥有消费者密钥/消费者</e
浏览 2提问于2012-08-01得票数 13
回答已采纳
通过googling搜索，似乎并不是真的推荐使用表来实现生产者/消费者模式。最棘手的部分是拥有多个消费者。我是不是误解了什么，比如事务智能、锁定等？
浏览 0修改于2014-04-03得票数 0
如果RabbitMQ的消费者崩溃，并且没有正常断开连接，那么几毫秒后触发的后续请求是否会报告消费者计数减少？或者，在报告的数字发生变化之前，是否需要经过一段时间？
浏览 2提问于2014-07-16得票数 0
让我们假设这样的场景:我有四个分区，一个消费者组有二十个消费者。因此，只有4个消费者将工作，16个消费者将处于饥饿模式。如何优化其他16个消费者，以便让每个消费者都能正常工作，或者我们如何优化这种情况？
浏览 36提问于2020-04-02得票数 0
我试图找出是否有任何抵消消费者群体的水平以及。消费者抵消是在消费集团层面，还是在卡夫卡消费集团内部的个人消费者？
浏览 1修改于2020-10-19得票数 3
回答已采纳
2回答
当我们有多个消费者从单个分区的主题中读取时，所有消费者都有可能得到所有的消息。我已经创建了两个消费者，手动偏移commit.started，第一个消费者，2分钟后启动第二个消费者。第二个消费者正在从第一个消费者停止读取的消息中读取。有没有可能第二个消费者会从头开始阅读所有的信息。我是卡夫卡的新手，请帮帮我。
浏览 24修改于2019-02-10得票数 0
我刚接触Kafka，到目前为止，我对消费者的理解是，基本上有两种类型的实现。2)
高级抽象最重要的部分是当Kafka不关心处理偏移量时使用它，而简单的使用者对偏移量管理提供了更好的控制。让我困惑的是，如果我想在多线程环境中运行消费者，又想控制我使用的消费者组，这是否意味着我必须从存储在zookeeper中的最后一个偏移量开始读取？这是我唯一的选择吗。
浏览 1提问于2013-08-01得票数 7
1回答
如何配置消费者，使其在单次轮询中一次轮询50条记录。我已经创建了消费者，并将max_poll_records设置为50。但是我的消费者正在使用time.how中的单个记录来配置消费者，以便在一次轮询中获取50条记录。
浏览 13修改于2019-02-11得票数 0
我试图在C中使用pthread实现生产者/消费者问题。我有一个全局变量int num_available作为我的两个条件变量fill和empty的状态变量。这是我的生产者代码，它可以填充工作并向消费者发出信号。pthread_cond_signal(&fill); }}
制作者得到锁，项目:0消费者:锁定，项目:1<em
浏览 0提问于2018-03-17得票数 0
回答已采纳
我想使用RabbitMQ实现竞争消费者，我有两个(或更多)消费者：消费者2可以使用“红色”和“黑色”类型的信息。现在，我希望使用竞争的使用者模式在消费者之间进行负载平衡(可能还有更多具有相同配置的消费者实例)，并且我希望保持消息排序“松散”完整(我不需要完美的排序，但希望从2小时前开始处理消息，而不是2分钟前的消息示例:我想以以下方式处理以下消息：
红色:先完
浏览 0修改于2019-02-28得票数 0
我在Java中有一个具有多个消费者的生产者-消费者模型。我在生产者和消费者之间传递一个对象，这个对象有一个变量，我们称它为"name“。
现在，这个名称可以是A、B或C。如果值是A，则一个消费者将从队列中取出它并对其执行某些操作。如果该值为B，则不同的使用者会将其从同一队列中取出，并执行其他操作。如果该值为C，则第三个消费者也会执行同样的操作。
浏览 1提问于2013-02-25得票数 2
我试图用java编写一个生产者-消费者模式。我是一个网络客户端，通过一系列不同的连接连接到许多服务器。服务器产生不同的“工作”包，这些包都被放入一个阻塞队列中。我想要做的是阻止我的消费者，因为只有特定类型的工作包才会被传递给特定的消费者。
在java.util有标准的课程吗.还是我要自己上课？另外，如果需要的话，有什么最好的方法来做自己的事呢？
浏览 2提问于2012-07-10得票数 1
回答已采纳
我正在设计一个系统，其中将有n生产者和m消费者，其中n和m是数字，n != m。
在java中，如果我使用同步关键字，那么它将阻塞相应的调用方。
浏览 5提问于2015-04-30得票数 4
所以我已经模拟了我的生产者消费者问题，我有下面的代码。我的问题是:如果消费者处于常量while(true)中，他如何停止。但在我的实际设计中，这是行不通的(有时生产者需要更长的时间来‘放置’数据，所以抛给消费者的异常是不正确的。一般来说，我知道我可以放入一个“毒药”数据，比如Object is XYZ，我可以在消费者中检查它。但是这种毒药让代码看起来真的很糟糕。不知道是否有人有不同的方法。
浏览 0提问于2012-04-27得票数 7
回答已采纳
因此，总共有50名消费者。我希望负载水平地分布在所有的消费者身上。因此，每个使用者读取一个分区，其中两个除外，因为消费者总数少于整个分区数。
每个使用者尝试从每个找到的主题订阅一个分区。在这种情况下，我可以让所有的消费者开始工作。或者有一种不同的方法允许读取多个主题，涉及分区的数量和运行的使用者？
浏览 3修改于2022-07-19得票数 1
回答已采纳
我正在做一个关于oauth的项目。我必须要求用户登录到第三方网站(谷歌，facebook，msn，链接)通过oauth.我在该项目的开发阶段。在上面的链接中，它已经说到了作为python的要求。任何帮助..。谢谢
浏览 0修改于2012-03-07得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号