我有两个具有相同组id的消费者服务器订阅了相同的主题。kafka服务器运行时只有一个分区。据我所知，消息应该在这两个消费者服务器中随机消费。但现在似乎总是同一个消费者服务器A消费消息，另一个不消费messages.If我停止消费者服务器A，另一个将正常工作。我所期望的是他们可以随机消费消息。
浏览 2提问于2016-04-05得票数 0
我的系统如下所示：我有N个消息生产者，N个RabbitMQ实例，N个消息使用者和1个服务。生产者产生相同的消息，而消费者使用相同的消息。这就是问题所在。使用者必须就谁调用服务API达成一致，因为使用相同的消息两次调用服务API会导致错误。我不知道消费者怎么能决定谁打电话给服务。
我有一些想法。我们可以创建一个RabbitMQ集群(使用一个检
浏览 0提问于2019-11-05得票数 1
在我安装的同一台服务器上：我不使用API的嵌入式微集成，因为它没有任何数据服务功能(顺便说一句，我不知道如何启用它们。)apim_host = "https://localhost:9443"
浏览 11提问于2022-11-23得票数 1
回答已采纳
我的团队正纠结于如何使用消息总线来构建我们的微服务。
我们目前有一个API网关，它背后有许多微服务，都是通过http进行通信的。在研究了实现消息总线(Kafka)之后，团队在使用者和API是否应该存在于同一服务中，或者它们是否应该是两个单独的服务的问题上存在分歧。一些人认为它们应该分开，因为它们有不同的扩展关注点，而另一些人认为它们应该在相同的服务</em
浏览 13提问于2018-01-29得票数 0
回答已采纳
1回答
.Net核心中的卡夫卡消费者
、、、、
我想在我们基于微服务的项目中使用Kafka作为消息代理。实施消费者的最佳做法是什么？我们是否应该在WebApi中实现为后台服务添加托管服务或独立控制台应用程序？由于侦听队列的无限循环，出于性能和损坏的原因，我对在API项目中使用有疑问。尽管如此，我还是必须在WebApi中使用模型和类。为了便于扩展，最好为使用者使用专用线程并使用控制台应用程序。我想知道是否有任何最佳做法或范例，以实
浏览 6提问于2020-01-15得票数 3
回答已采纳
我们是否可以在RabbitMQ中设计发布-订阅模式，其中消费者也可以充当生产者并将消息发送到消息代理？ pub-sub with the same service
浏览 47提问于2020-02-01得票数 0
回答已采纳
1回答
我有一个微服务，它公开rest端点来显示计费数据。在同一个微服务中，我有消息侦听器(最大50和最小10 )，用于侦听队列和处理账单。在微服务中使用消息消费者是否是一种好的做法，因为它将长期运行。
浏览 3提问于2018-11-28得票数 0
当遵循微服务架构时，在哪里以及如何使用kafka (用于服务间消息通信？)我的理解是否正确，如下所示？
客户端(网页) ->通过API网关-> Lamdba ->请求(CRUD)消费者信息。现在，我应该直接在Lambda中更新消费者信息，还是应该向kafka发送一个事件来更新数据？客服是否应该发送像customer_updated这样的事件来通知其他服务更新？另外，我的理解是，每个微服务</
浏览 14提问于2020-02-21得票数 0
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
我正在使用Knative Eventing (Kafka Source，它读取kafka集群中的数据)来触发消费者服务，如果事件/消息没有成功处理(可能是任何原因)，我希望自动重新传递消息。我试着通读了文档和API参考，但不清楚这是否可行。问题:在Knative上，一旦KafkaSource将消息发送到消费者服务，消费者服务将处理请求并发送http错误代
浏览 6提问于2020-07-24得票数 1
我正在使用rabbitmq在微服务中的两个服务之间发送消息。如果是，是否可以通过RabbitMQ管理HTTP
浏览 8提问于2017-02-23得票数 0
回答已采纳
1回答
我想要在我的计划查询完成后尽快得到结果，Big query scheduler API提供pub-sub通知，但消息不包含任何关于结果的内容。有一个消费者服务正在等待调度查询结果，我们希望在结果准备就绪并且服务可以开始使用它时通知消费者服务，我们如何实现这一点？结果存储在表中，但有多个调度查询将结果写入到同一个表中，因此消费者服务不能只读取我的表，因为我们需要一些偏移量。那么对此有
浏览 2提问于2021-08-10得票数 1
1回答
对于服务/进程既是API服务器又是后台工作人员，从像SQS这样的队列中消耗消息，您有什么想法？我通常将这两项任务分开，以保留每个任务的单个责任，但至少在NodeJS中，让API服务器引导自身成为API服务器，然后开始轮询队列以查找要完成的任务，这似乎很奇怪。将两者混入同一个服务中是一种相当普遍的做法吗？如果不是其他强有力的理由让他们分开呢？同样，同样的逻
浏览 0提问于2021-06-29得票数 0
我使用ServiceStack已经有一段时间了，我很清楚基于消息的API设计是首选的，这也是我在一些基于REST的API中使用的东西。我现在正在研究Redis / MQ库，并且一如既往地喜欢ServiceStack的结构和功能。但是，我正在考虑用MQ服务器替换一些遗留的通信代码，并使用，它工作得很好。当我在具有处理程序的消费者中做这样的事情时：
mqHost.RegisterHandler<GetSomething>(base.ExecuteMes
浏览 3提问于2020-05-06得票数 1
1回答
我是设计系统的新手，对消息队列和协调服务(Zookeeper)有一些疑问。我对我正在设计的系统中的MQ的理解：1)如果我希望我的
浏览 1提问于2016-04-26得票数 0
假设您有一个由一个生产者(P1)和许多消费者(C1-C2-C3)组成的体系结构。当一个小型java客户机按顺序生成消息为M1、M2、M3和另一个java客户机(3倍扩展到另一台机器)时，将收到一条消息，然后在计算完后将消息写入数据库表。如果消费者应用程序中的计算周期不同，而最初使用的消息可能会以最后一个顺序写入同一表，则可能会导致数据不一致。
也许我遗漏了一些文档中的东西，但我想知道kafka在这种情况下如何处理一致
浏览 1提问于2018-03-04得票数 1
回答已采纳
使用RabbitMQ，有没有一种方法可以将消息从队列“推送”到消费者，而不是让消费者“轮询并从队列中提取”消息？
这已经引起了一些关于我正在做的项目的争论。一方的论点是，让消费者(即，windows服务)在新消息到达之前“轮询”队列在某种程度上是低效的，并且比使消息从队列自动“推入”到订户/consumer(多个)的想法更不可取。我似乎只能找到支持消费者“轮询并从队列中拉出”消息的想法的信
浏览 1提问于2014-10-23得票数 17
消费者代码如下：from kafka.consumer import SimpleConsumer
consumer.seek(0, 2) print message
然后我用脚本生成消息kafka-console-producer.sh --broker-list localhost:
浏览 0提问于2014-02-16得票数 2
回答已采纳
2回答
我怀疑我是否使用了正常的publisher /订户模式，订阅者和publisher都是在同一个线程上运行还是在不同的线程中运行？
还是取决于实现？
浏览 4提问于2016-12-02得票数 2
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号