如何一次使用多个订阅者从主题中读取消息？
await subscriptionClient.CompleteAsync(message.SystemProperties.LockToken);
我遵循这篇文档来实现上述场景。
那么，有没有人可以建议我如何一次使用多个订阅者从主题中读取消息。
共有1个答案
每当一个订户从topic读取消息时，这些消息就会进入死信队列。这就是为什么第二个订阅者将无法从主题中读取消息的原因。
有处理逻辑错误，消息被重试，直到它被移到死信队列，或者您将maxDeliveryCount设置为一次处理尝试。无论哪种方式，请检查deadletterreason和deadlettererrordescription头/属性，以了解消息被移入死信队列的原因。
有没有人可以建议我如何一次使用多个订阅者从主题中读取消息。
Azure服务总线支持竞争的消费者模式，您不必做任何特别的事情。
-
首先，我知道这里已经有一个类似问题的答案了，但我仍然不能确定这是因为RabbitMQ的不可能，还是因为我研究得不够。 我来自事件pub/sub模式是这样工作的JS/Node背景：当许多消费者用pub/sub模式订阅同一个主题时，无论何时某个生产者发布它，所有人都应该得到相同的消息。 我希望用消息代理实现相同的模式。 例如： 生产者%1发布到主题 生产者2发布到主题 RabbitMQ的实际操作（根据
-
我正在配置一个Apache Artemis消息代理。代理将接受大文件，下游消费者访问该主题以处理最新文件。现在我想知道如何使最新文件可用于开发运行。因为消息一天只到达几次，所以测试运行需要访问最近发送的几条消息，不能等待下一条。 对于生产和登台系统，我发现持久订阅工作良好。我已经改编了ApacheCamel配置作为示例。以下是两个接收消息的消费者，每个消费者都使用持久订阅： 这很好。如果一个消费者
-
我有一个简单的java制作人，如下所示 我正在尝试读取如下数据 但消费者并没有从Kafka那里读到任何信息。如果我在处添加以下内容 然后消费者开始从题目开始阅读。但是每次消费者重新启动时，它都从我不想要的主题开始读取消息。如果我在启动消费程序时添加了以下配置 然后，它从主题中读取消息，但是如果消费者在处理所有消息之前重新启动，那么它不会读取未处理的消息。 有人可以让我知道出了什么问题，我该如何解决
-
我有以下代码 我的问题：当我添加多个主题订阅时（即上面的A，B，C），Kstream代码停止接收记录。 参考文献：https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/StreamsBuilder.html 相关文件 我想实现的是：让一个Kstream（即上面的“源”）消耗/处理多个主题。
-
我正在使用spring boot构建一个web应用程序，现在我需要接收实时通知。我正计划使用apache kafka作为这方面的消息代理。要求用户具有不同的角色，并且根据角色，他们应该接收其他用户正在执行的操作的通知。 我设置了一个生产者和消费者，作为消费者，我可以接收发布到一个主题的信息，比如说topic1。 我遇到的问题是，我可以让多个用户收听同一个主题，而每个用户都应该得到发布到该主题的消息
-
问题内容： 我有一个简单的Java生产者，如下所示 我正在尝试读取以下数据 但是消费者没有阅读来自kafka的任何消息。如果我在下面添加以下内容 然后，消费者开始阅读该主题。但是，每当使用者重新启动时，它都会从我不希望的主题开头读取消息。如果我在启动Consumer时添加以下配置 然后它从主题读取消息，但是如果使用者在处理所有消息之前重新启动，则它不会读取未处理的消息。 有人可以让我知道出了什么问