确保来自SQS的消息在给定时间被单个消费者使用
这里我的问题是，当一个消费者正在处理一条消息时，队列中的其他消息是否有可能被另一个消费者消费？
如果是，如何确保在给定的时间只有一个使用者在使用队列中的消息？
共有1个答案
队列中的其他消息会被另一个使用者使用？
如果它们在不同的消息组中，那么不同的消息可以被其他消费者读取。但如果FIFO队列中的所有消息都属于同一组,则它们的顺序和处理由AWS保证：
属于同一消息组的消息总是按照相对于该消息组的严格顺序逐个处理（但是，属于不同消息组的消息可能被处理得不按顺序）。
-
有没有任何选项或配置可以方便单个Kafka消费者同时消费来自两个不同集群的消息？在创建生产者和消费者时，我将两个集群都提到逗号分隔。我一直在观察消费者只消费来自单个集群的消息。 请参阅下面的说明：消费者C1被配置为监听集群：集群-1：Zooker-1 with Broker-1集群-2：Zooker-2 with Broker-2 我正在寻找一种解决方案，其中消费者C1可以同时消费来自集群1和集群
-
D： \软件\Kafka\Kafka2.10-0.10.0.1\bin\windows 我使用上面的命令来消费消息，有什么我错过的吗？帮助我： 这个 那些是生产者和消费者......
-
生产者发送消息到一个有四个分区的主题。我们有一个消费者在消费来自这个主题的消息。应用程序在工作日一直运行周末例外：它不会在周末期间调用poll方法。 使用者配置：自动提交，自动提交时间为5s（默认）。 应用程序一直运行良好，直到一个星期天，当它重新开始调用poll方法。我们看到有数百万条消息从这个话题中被轮询出来。消费者基本上是轮询来自主题的所有消息。将新的偏移量与它在周末停止之前的偏移量进行比较
-
我有一个Kafka主题，目前有3个分区。我希望我的消费者从同一个分区读取，但每条消息都应该以循环方式发送给不同的消费者。有可能实现吗？
-
我用java编写我所有的微服务。我想在Amazon SQS中使用多个消费者，但每个消费者在负载均衡器后面的AWS上有多个实例。 我使用SNS作为输入流 我在SNS之后使用SQS标准队列。 我在stackoverflow上发现了同样的问题（使用多个消费者的Amazon SQS） 此示例为 https://aws.amazon.com/fr/blogs/aws/queues-and-notificat
-
我正在查看关于使用Quarkus从SQS消费的指南。 问题是我想在无休止的循环中执行它，例如每10秒获取一次新消息，并使用Hibernate Reactive从消息中插入一些数据到数据库中。 我创建了一个Quarkus调度程序，但由于它不支持返回Uni，我不得不阻止Hibernate Responsive的响应，因此出现了这个错误 使用Quarkus和reactive实现我所需的最佳方法是什么？