《快消实习》专题

本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费

我有一个具有必需属性的字段。当我按下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

我们有一个非常简单的Kafka Consumer（v 2.6.2）。它是使用者组中唯一的使用者，并且该组是唯一一个阅读主题的组（有6个分区，其中有大约300万个事件）。Broker也是2.6.x版本 由于我们需要实现一个“只有一次”的场景，我们深入研究了一下，如果我们真的只使用一次写入主题的每个事件。不幸的是，我们发现：消费者有时会跳过一个偏移量，有时甚至会跳过一组分区的偏移量。 消费者除了记录之

我有一个基本的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应用程序。 版本： 问题是对于一个特定队列的消费者

在一个消费者群体中的所有消费者都失败后，kafka会将该消费者群体的补偿存储多长时间？是否有此配置变量？

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

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

ActiveMQ中的持久主题（这似乎是JMS本身的一个障碍）似乎是一个订阅服务器上只能有一个使用者活动。 也就是说，在ActiveMQ文档中： 使用唯一的JMS clientID和持久订阅服务器名称创建JMS持久订阅服务器MessageConsumer。为了符合JMS，对于一个JMS clientID，在任何时间点只能有一个JMS连接处于活动状态，对于一个clientID和订阅者名称，只能有一个使

我使用RabbitMQ作为不同消息的队列。当我使用来自一个队列的两个不同消费者的消息时，我会处理它们并将处理结果插入数据库： 我想大量使用队列中的消息，这将减少数据库负载。由于RabbitMQ不支持消费者批量读取消息，我将这样做smth： 消息在全部完全处理之前处于队列中 如果消费者跌倒或断开连接 - 消息保持安全 你认为这个解决方案怎么样？如果可以的话，如果消费者摔倒了，我怎样才能重新得到所有未