《消息》专题

生产者发送消息到一个有四个分区的主题。我们有一个消费者在消费来自这个主题的消息。应用程序在工作日一直运行周末例外：它不会在周末期间调用poll方法。 使用者配置：自动提交，自动提交时间为5s（默认）。 应用程序一直运行良好，直到一个星期天，当它重新开始调用poll方法。我们看到有数百万条消息从这个话题中被轮询出来。消费者基本上是轮询来自主题的所有消息。将新的偏移量与它在周末停止之前的偏移量进行比较

我正在构建一个使用来自Kafka主题的消息并执行数据库更新任务的Kafka消费者应用程序。消息是每天一次大批量生产的--所以该主题在10分钟内加载了大约100万条消息。主题有8个分区。 Spring Kafka消费者（使用@KafKalistener注释并使用ConcurrentKafkaListenerContainerFactory）在非常短的批处理中被触发。 批处理大小有时仅为1或2条消息。

我们有一个Kafka制作人，偶尔会制作一些信息。 我写了一个消费者来消费这些消息。问题是，只有当两个消息叠加时，它们才会被使用。例如，如果消息是在13:00产生的，消费者不做任何事情。如果另一条消息是在13:01生成的，则消费者会使用这两条消息。在kafkaTool中，在消费者属性中有一个名为LAG的列，当消息未被消费时，该列为1。我缺少的这个东西有什么配置吗？ 消费者配置：

面试题 如何保证消息不被重复消费？或者说，如何保证消息消费的幂等性？ 面试官心理分析 其实这是很常见的一个问题，这俩问题基本可以连起来问。既然是消费消息，那肯定要考虑会不会重复消费？能不能避免重复消费？或者重复消费了也别造成系统异常可以吗？这个是 MQ 领域的基本问题，其实本质上还是问你使用消息队列如何保证幂等性，这个是你架构里要考虑的一个问题。 面试题剖析 回答这个问题，首先你别听到重复消息这个

我有一个具有必需属性的字段。当我按下Accept（接受）按钮保存一些数据而不在字段中输入任何值时，将显示一条错误消息。到现在为止，一直都还不错。但是，如果在此之后我决定单击“取消”按钮，则该错误消息将覆盖应该显示在

我是Kafka的新手，运行一个简单的Kafka消费者/生产者的例子，就像在Kafka消费者和KafkaProducer上给出的那样。当我从终端运行消费者时，消费者正在接收消息，但我不能使用Java代码监听。我也在StackoverFlow上搜索了类似的问题（链接： Link1，Link2），并尝试了解决方案，但似乎没有什么对我有用。kafka版本：和相应的maven依赖在pom中使用。 Java生

我已经建立了一个由3个节点组成的AWS集群。我修改了节点的/etc/hosts文件，看起来像这样 当我从其中一个节点运行命令时 bin/kafka-console-consumer.sh --bootstrap-server kafka1：9092 --topic first_topic --from-start 它可以工作，但是当我用ip替换主机名并用下面的命令运行它时 bin/kafka-co

这与以下问题几乎相同：发送给具有相同消费者组名称的所有消费者的消息。公认的答案是使用Kafka 0.8.1或更高版本，我就是这么做的。 Kafka留档说： 如果所有使用者实例都具有相同的使用者组，则其工作原理就像在使用者之间平衡负载的传统队列一样。 但是我无法使用 Kafka 0.8.2.1 和 kafkacat 观察到这种行为。 我的设置： Kafka Zookeeper 运行在 spotify

我有一个基本的SQS队列，它使用redrive策略触发Lambda，在5次重试后将失败的消息发送到DLQ。我读到Lambda应该在消息中添加关于错误的消息属性 除了在DLQ中查看消息时，我没有看到任何来自Lambda的ErrorCode、ErrorMessage属性外，其他一切都正常工作。有人用这个吗？

我正在尝试用spring cloud stream实现spring cloud契约。我有一个使用StreamBridge的制作人 方法sendMessage（）是从rest控制器调用的。 我的合同是这样的： 当我运行测试时，会调用triggerCreateOrganization（）方法，并在日志中看到日志消息“生产组织到主题”。 我在生成的测试的基类上有@AutoConfigureMessage

我可以在命令行上针对Kafka位置安装发送和接收消息。我也可以通过Java代码发送消息。这些消息显示在Kafka命令提示符中。我还有一个Kafka消费者的Java代码。代码昨天收到了消息。但是今天早上没有收到任何消息。代码没有更改。我想知道属性配置是否不太正确。这是我的配置： 制片人： 生产记录设置为 消费者： 对于Java代码： 少了什么？

我的应用程序使用来自RabbitMQ的一些消息并对其进行处理。我有大约10个队列，每个队列最多有10个消费者（线程）。我有5次预回迁。我正在Heroku中使用CloudAMQP插件（RabbitMQ作为服务）运行安装程序。 我使用默认心跳和连接超时设置（60秒）运行。 我的java应用程序是一个使用sping-Rabbit库的Spring Boot应用程序。 版本： 问题是对于一个特定队列的消费者

我想创建没有按钮的消息框，这将消失，例如2.5秒后。我知道我可以使用并将其放入线程中而不是杀死它，但也许还有更好的方法。如果没有，如何创建空消息框？

我想在SQS上发布一条消息，并在几个小时后处理该消息。 如何根据某些属性安排消息传递或从SQS中选择消息？ 我已经实现了一个SQS消费者，但我正在接收来自SQS队列的每条消息。有可能在SQS上实现类似的功能吗？我正在考虑接收每条消息，如果还没到处理该消息的时间，就再次发送到队列。

null null 谢了。