回答情况：
提问时间：
问题标签：
在下游系统不可用的情况下，消费者不要确认Kakfa消息。因此，当我的消费者在下游系统不可用时收到消息时，kakfa的偏移量将不会被提交。但如果我在下游系统启动后收到新消息，并且当我确认该消息时，最新的偏移量将被提交，消费者将永远不会收到没有偏移量提交的主题中的那些消息。
也就是说，假设我的消费者被消耗到偏移量4。当下游不可用时，消费者收到两条消息，因此我的消费者没有提交偏移量。因此，toipc中的消息数量现在是6，但偏移量仍然是4。现在下游系统可用，消费者收到新消息(第
浏览 17提问于2019-08-01得票数 0
目前我的笔记本电脑上有Win7、Win8(消费者预览)和Ubuntu12.04。如果我想引导到Windows 7，我必须选择Windows 8加载程序，然后从windows启动菜单中选择Windoes 7。由于Win8加载器有点傻，它会重新启动pc以加载Win7，但是它只会带我回到GRUB2，我必须再次选择Win8加载程序，然后Win7才会启动。这是失败，长篇大论，无懈可击。如果我可以将Windows 7添加到GRUB菜单中，然后从那里选择它，而不是引导Windows
浏览 0修改于2012-05-30得票数 3
但是，如果我的消费者目前没有运行，并且我将一些消息推送到主题，并再次启动消费者，它不会消费生产者推送的消息，但它再次准备消费现在将被推送的消息。例如消费者正在运行：结果:消费者将消费所有三条消息。案例2producer现在将m4，m5 m6消息推送到主题1的分区1结果:消费者不消费消息m4、m5、m6，但如果我检查偏移量，则将其设置为7。这意味着生产者在生成消息时将偏移量提
浏览 1提问于2014-12-05得票数 1
我有以下情况：
Partition 1: [0] [2] [5] [6] [8]当事件使用者开始阅读时，每个消费者最终只会看到事件的一部分，如下所示：Con
浏览 4修改于2021-07-19得票数 1
回答已采纳
服务器和消费者操作系统有什么区别?我想到的例子是Windows7和Windows 2008 R2?
为什么我不应该在服务器上运行Windows 7呢？这里有几个很好的问题，解释了消费者和服务器级硬件的复杂性，但除了服务器操作系统没有预装消费者软件和媒体播放器等功能外，我在操作系统上找不到什么。
浏览 0修改于2017-04-13得票数 2
以下是三种流动和状态：Flow 1从“提供者节点”到“消费者1节点”，Flow 2从“消费者1节点”到“消费者2节点”和提供者节点。第二天，2021年7月8日，我重新启动了节点。
我启动了从“消费者
浏览 4修改于2021-07-09得票数 0
我有一个kakfa主题，有20个分区和5个conusmers属于同一个消费者组。这意味着我们每个消费者有4个分区。让我们说：
将分区-0分配给分区-0，分区-1，分区-2和partition-3consumer-1分配给分区-4，分区-5，分区-6和partition-7consumer-2分配给分区-8，分区-9在这种情况下，只有分区0、1、2、3、4、5、6、7、8和9才会接收消息。剩下的都是空的。我们的问题是，消费者-0和消费者-1将处理4条消息，同时，消费者-2
浏览 4修改于2020-10-22得票数 3
但在我的例子中，消费者的工作要复杂得多，而且需要一些时间。所以我想要4个用户并行地处理数据。
例如，如果生产者生产数字:1，2，3，4，5，6，7，8，9，10，11。我要consumer1抓到1,5,9，.consumer2捕捉2,6,10，.consumer3捕捉3,7,11，.consumer4捕捉4，8，12.当然，我可以创建4个环形缓冲器，并将1个消费者附加到1个环形缓冲区。这样我就可以使用原始的例子了。但我觉得这是不对的。创建一个发布者(1个林格缓冲区)和4个消费者可能是正确的，因为这是我所需
浏览 7修改于2017-05-23得票数 7
回答已采纳
a: 1标志:1计数1 TID 1消费者a: 2标志:1计数2 TID 1消费者a: 3标志:1计数3 TID 1消费者a: 4标志:1计数4 TID 1消费者a: 5标志:1计数5 TID 1消费者a: 6标志:1计数6 TID 1消费者a: <
浏览 2修改于2011-02-26得票数 3
回答已采纳
我有一个带有折扣/交易的应用程序，用于需要在特定日期时间(即从1st January 2022 7:00 am到31st January 2022 5:00 pm )之间启用的项。例如，该交易的用户是在马来西亚GMT+8为他们在印尼各地的终端消费者(这里有三个独立的时区GMT+7、GMT+8和GMT+9)以及新西兰的一些其他终端消费者(那里有夏令储蓄和GMT+12和GMT+13交替使用因此，GMT+13的消费者必须观察1st Jan 7am中的交易，而GMT+7</em
浏览 4修改于2022-07-11得票数 0
回答已采纳
我有Kafka服务器2.4版本，并设置了log.retention.hours=168(so，主题中的消息将在7天后被删除)和auto.offset.reset=earliest(so，如果消费者没有得到最后提交的偏移量我的主题数据是：1,2,3,4,5,6,7,8,9,10端偏移量：10因此，假设我的消费者在过去的7天里没有跑步，我已经在第8天开始消费了
浏览 1修改于2021-04-14得票数 6
回答已采纳
1回答
我们有7个经纪人和40个消费者在卡夫卡的设置。所有节点(对于代理和消费者)都具有合理的配置、托管和AWS，我们在任何一台机器上几乎看不到任何尖峰。但不知何故，我们发现消费者的滞后性很高，尽管增加了40名消费者来满足上述设置的阅读需求。这是尽管事实，我们只有大约215条消息(每条消息的大小约2KB )的摄取每秒，上述主题。我们还可以看到，大多数情况下，消费者都处于闲置状态，偶尔也会使用这些消息。40个消费者是否足以处理上述场景(40个主题有40个分区，每个主题每秒大约有2
浏览 0提问于2018-11-10得票数 2
回答已采纳
投入工业1工业2消费者自由裁量3 4公用事业6工业7消费者自由裁量8金融9金融11金融13消费者自由支配14消费者自由支配15公用事业16公用事业17消费者自由裁量18消费者自由裁量19公用事业20Output Top 3行业15家财务公司36家公用事业53家消费者自由裁量52
浏览 1修改于2015-08-20得票数 1
但在我的例子中，消费者只有在先前的使用者确认其消息之后才会顺序地接收消息。}消费者2:开始处理...。消费者7:处理结束。
消费
浏览 5修改于2016-10-31得票数 6
回答已采纳
我正在尝试在消费者端验证合同时使用场景(也称为状态)。logout.groovy "uuid" : "34a829d1-adf4-41e4-b7d9-6ee66d7de8bc", "url" : "/foo/demo",
"method&
浏览 14提问于2017-01-25得票数 0
我得了observable of KeyValuePair<int,double>我得到了一个在运行时定义的使用者列表例如：
消费者1只对myKey = 1的值感兴趣，所以这里没有。myObservable.Where(t => t.Key == myKey).Subscribe(t =&g
浏览 1修改于2020-11-29得票数 1
回答已采纳
一位消费者遇到了一条毒药药丸的信息，但并没有放弃它。没有人注意到很长一段时间(15天)。该专题的保留期为(7天)。假设这个毒丸位于日志段文件中，该文件满足了保留期所需删除的要求。
会发生什么？是否允许删除此日志段文件，而消费者正在尝试从中读取？是否删除日志段文件，并让消费者使用auto.offset.reset设置查找开始读取的位置？
浏览 2提问于2020-11-04得票数 1
回答已采纳
我在一个队列上有8个消费者，它们中的任何一个都可以拾取消息，一旦被处理，这就会影响数据库。大多数消息都可以异步运行，但在少数消息上，我们需要停止队列消费，直到该消息被其中一个消费者完全处理。在此期间，其他7个消费者不应该从队列中消费。
有没有办法在rabbitmq中实现它，而不是做一个应用程序级别的解决方案(这可能很难实现)？
浏览 1提问于2014-02-10得票数 0
当我创造了9个消费者..。六号正在闲置。只有三个消费者被使用。例如，我有三个主题-- Topic_A、Topic_B和Topic_C --以及三个分区。Topic_B_1,Topic_C_1 Consumer4,Consumer5,Consumer6,Consumer7,Topic_
浏览 0修改于2018-07-13得票数 1
4回答
我在同一个消费者组中启动两个消费者，我订阅了20个主题(每个主题只有一个分区)。只对消费者使用：
rdkafka-07cbd673-6a16-4d55-9625-7f0925866540
浏览 0修改于2018-08-06得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号