回答情况：
提问时间：
问题标签：
我使用的是rabbitmq 3.6.6，使用的是对接者图像"rabbitmq:3“当我在通过rabbitmqctl执行list_consumer时，我在列表中看到了消费者
浏览 2提问于2017-01-31得票数 0
回答已采纳
我通过新的消费API创造了卡夫卡消费者。我们有一个使用者组，每个组中有一个使用者实例。Kafka脚本“kafka- old groups.sh”提供了删除用户的方法，但这只适用于运行命令的旧使用者组：给出
--删除：警告:组删除只适用于旧的基于因此，我想问一问，是否有任何方法删除通过新的消费者API创建的消费者组？
浏览 2修改于2022-02-22得票数 7
Kafka支持消费者消费以前产生的任何信息。(通过重新加宽卡夫卡日志中的“偏移”)
我想知道RabbitMQ是否具有相同的功能。(一个新的使用者会在某一点之后请求所有消息。)
浏览 2提问于2016-06-29得票数 1
回答已采纳
现在我使用kafka控制台使用者(新的)：sudo bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testTopi
浏览 1提问于2017-06-14得票数 0
有几个消费者在更新他们自己的数据库，并保持他们的客户数据的最新。
解决这种情况的最佳做法是什么？我们是否需要触发生产者再次为所有客户生成一条消息(重新处理所有消息)？我们应该在Kafka之外建立新的消费者数据库吗？还有其他解决办法吗？
浏览 3修改于2022-07-27得票数 0
回答已采纳
如果我运行的是一个处理一组消息的Kafka消费者，然后在处理消息时，我将第二个消费者添加到同一个消费者组中，我会多次获得整个消息集，而不仅仅是一次。每个主题有两个分区-每个消费者一个。然后测试将20条消息添加到大容量队列中，然后将10条消息添加到活动队列中。当一个新的消费者出现时，我是不是遗漏了什么来阻止它重播所有的消息？还是这只是我要处理的事？
干杯
浏览 0提问于2019-01-21得票数 1
我们正在将kafka实现升级到.9，并使用新的使用者java来创建使用者。我正在为消费者使用下面的代码，我们使用对消费者设置主题，如A行和B行是对我们的服务的调用，它处理我们接收到的消息。
浏览 1修改于2016-08-18得票数 6
回答已采纳
我的目标是让消费者用特定的主题连接到代理。一旦检测到此连接，代理将传递消息，如果生产者正在主动生成该主题，或者代理将为该特定主题启动一个新的生成器。然而，要做到这一点，我需要有人检测什么时候一个新的消费者连接和要求一个特定的主题。我的基本消费代码： ConnectionDEBUG tRegion - localhost addin
浏览 6提问于2016-10-05得票数 0
我使用rabbitMQ将任务发送给运行时创建的工作人员(消费者)。当前，每次创建新任务时，都会创建一个新的工作人员。我已经检查了rabbitmq的管理部分，并且有两个被绑定到队列的消费者，但是其中一个似乎完成了所有的工作，而另一个只在等待。
浏览 4提问于2015-12-29得票数 2
回答已采纳
1回答
我需要创建一个新的费用卡，输入参数是数量，日期和描述。
必须在费用卡中填写的字段才能创建它：
持卡人是联系月费用申请是一个自定义对象。创建费用卡时，如果在“日期”字段中输入的日期前存在月份费用申请，则创建一个新的费用卡，从现有的支出申请中提取月份费用申请。如果在“日期”字段中输入的日期之前没有月费用申请，则需要创建月费用应用程序，然后创建一个费用地图，其中月份费用应用程序将创建一个新的月费用应用程序。
浏览 8修改于2022-11-10得票数 1
回答已采纳
我是卡夫卡世界的新手，我读过关于消费者和消费者群体的文章，我理解了他们之间的区别，理解了为什么我们需要卡夫卡的ConsumerGroup。但在这里，我的问题是，什么时候我们应该决定什么时候在同一个集团内创造新的消费者。当我们有大量数据的时候？谢谢
浏览 0提问于2018-11-21得票数 0
回答已采纳
我正在尝试使用Java API监视给定组的消费者偏移量。我创建了另一个消费者，它不订阅任何主题，只是调用consumer.committed(topic)来获取偏移量信息。这种方式是可行的，但是：我猜这与再平衡有关，可能被非订阅的消费者搞混了。这有可能吗？
浏览 0提问于2016-02-11得票数 1
我正在构建一个websocket后端，它将连接到一个主题(只有一个分区)，并从最早的位置消费数据，并不断消费新数据，直到websocket连接断开。一次可以存在多个websocket连接。为了确保从头开始的所有数据都被使用，每次建立websocket连接时，我都会创建一个新的消费者组并订阅该主题 const Kafka = require('node-rdkafka')
const {但是，当我尝试将消费者/消费者组的数量超过4个时，<em
浏览 35修改于2021-11-15得票数 0
回答已采纳
kafka库(在中)还没有可用的暂停/恢复功能，所以我最终取消订阅/订阅了主题，而不是基于消费者消费者组，这似乎是我们想要的。如果添加了新的消费者组，但未完成任何操作，则上述命令不会显示该消费者组的相关信息。但是，如果新
浏览 10修改于2018-08-20得票数 0
使用新的Kafka Java使用者api，我运行单个使用者来消费消息。当所有可用消息都被使用完后，我用kill -15终止它。
现在我想重置偏移量开始。我想避免仅仅使用不同的消费者群体。我尝试的是下面的调用序列，使用与刚刚读取完数据的消费者相同的组。文档只说assign不支持subscribe，但我认为这只适用于一个消费者进程。(事实上，我甚至希望在另一个消费者启动时运行偏移量重置消费者，希望另一个消费者可以注意到偏移量的变化并重新开始。
浏览 0提问于2016-04-13得票数 3
我经常看到卡夫卡消费者得到当前抵消和滞后设置为未知的问题。G.AB_KAFF, T.AB_KAFF, 1, unknown, 11, unknown, consumer-2
卡夫卡是否删除了之前对该消费者的补偿，因为我不订阅整个消费群体的话题？
浏览 2修改于2016-06-29得票数 1
回答已采纳
它通过运行但是，当我运行新的kafka-console-consumer.sh --new-consumer --topic test --from-beginning \是否可以使用新的
浏览 26提问于2016-01-17得票数 43
consumer.properties我能够通过一个基于python的消费者连接到kafka，该消费者被配置为使用provide group.id，即test-consumer-group
首先，我不能理解kafka是如何/何时创建消费者群体的。它似乎会在某个时间点加载conf/consumer.properties，并且在通过kafka-consol
浏览 1修改于2020-08-16得票数 5
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号