《中邮消费金融》专题

上面的代码运行后输出 然后就没有然后了，程序没有退出，一直阻塞着 从 rabbitmq 的监控面板看，也一直出于阻塞状态 用 wireshark 抓包看，也没有回复 ack 为什么 ？

选择题10道还是15道来着，408和前端都有涉及到。算法题前端只有两道，第一题是输入两个数字字符串，不可以用bigint，求他们的乘积，输出也要是一个字符串。第二题是自然数按1 23 456 78910这样的规律排成一个三角形，然后输入一个字符串，里面有三个数字，要你判断这三个数是否在这个三角形里能组成一个等边三角形（比如3，5，6），输出true false。

时间：6.20 时长：10min左右 1. 自我介绍 2. 项目中遇到的困难？如何解决？原创还是开源？ 3. 八股：栈的大小；虚拟内存空间；new和malloc的区别；malloc相关的一个问题（忘记是什么了，没回答上）；左值引用和右值引用；按层遍历二叉树（队列）；top K的问题；TCP如何保证传输可靠；STL容器相关问题 4. 为什么投递这个岗位？对中金所的了解？和专业不匹配怎么看？在上海工作

我是 kafka 的新手，并试图了解是否有办法从上次使用的偏移量读取消息，但不是从头开始。 我正在写一个例子，这样我的意图就不会偏离。 有没有一种方法可以获取从上次使用的偏移量生成的消息。？

我目前正在做一个kafka java项目。我是新来的，我发现很难理解与Kafka生产者/消费者设计相关的几个基本概念。 > 比方说，我有一个带有单个分区的主题，我有一个生产者正在写这个主题，一个消费者正在从这个主题中消费。如果我部署同一个应用程序的多个实例，每个实例将运行自己的消费者。在这种情况下，因为所有消费者都属于同一个group pId，所以消息是否会在多个实例上运行的消费者之间平均分配？

使用Lagom 1.4.11，kafka 0.11与kafka的沟通似乎有效，因为制片人已经制作了一些东西。只有使用者有错误。 看起来我的µService与kafka没有任何联系。我有一个kafka-0 pod，kafka-zooker-0。 我安装了它 是他们能帮忙的人。谢谢你。 添加。 我发现制作人创造了主题: 似乎kafka不存储消息。

我有一个RabbitMQ设置，其中作业被发送到交换，交换将它们传递到队列。使用者依次正确地执行队列中的作业。但是，这些作业都是长流程（至少几分钟）。对于可伸缩性，我需要能够让多个使用者从队列顶部选择一个作业并执行它。 使用者正在一个叫做“队列”的Heroku dyno上运行。当我缩放dyno时，它似乎为每个dyno创建了额外的消费者（我可以在RabbitMQ仪表板上看到这些）。但是，队列中的任务数

使用redis stream实现消息队列，消费者在消费时每次都是同一个线程，无法并行消费！！！ 创建StreamMessageListenerContainer 线程池配置 啥原因呢，为啥这个线程池设置了没效果，每次都是同一个线程名称，有啥好的方法设置消费端并行消费呢？ 进入public StreamMessageListenerContainerOptionsBuilder<K, V> exec

我在用kafka-consumer-groups.sh工具重置我的滞后时发现了这一点。但是我需要在应用程序中重置它。发现了这个例子，但是好像没有重置。kafka-python在消费者重启后从最后产生的消息中读取示例 运行仍然显示两个分区都有一个LAG。如何将当前偏移量设置为“快速前进”到最后？

我运行生产者，它生成N条消息，我在仪表板上看到它们。当我运行接收器时，它会接收来自队列的所有消息，并且队列为空。 我需要有多个生产者生成消息到同一个队列。多个客户从队列中接收消息。消息将被队列TTL删除。但是现在第一个接收者从队列中获取所有消息。我怎么能做到这一点？

我们使用的是spring集成kafka版本3.1.2。RELEASE and int kafka：消息驱动的通道适配器，用于使用来自远程kafka主题的消息。生产者发送加密消息，我们使用反序列化器解密实际消息。我们可以使用主题中发布的所有消息。我们将自动提交用作false。我们想知道在成功处理消息后如何从我们的服务提交或确认消息。有人能帮助我们如何提交从消息驱动通道读取的消息并提供一些参考实现吗？

我正在为我的生产者和消费者应用程序使用Spring kafka事务。 要求在生产者方面有多个步骤：将消息发送到kafka，然后保存到db。如果保存到db失败，则希望回滚发送给kafka的消息。 所以在消费者方面，我将设置为，如果消息是从kafka回滚的，消费者不应该阅读它。 生产商应用代码为： 因此，我在saveToDb方法中显式抛出一个异常，并且可以看到异常抛出。但是消费者应用程序仍然可以看到消

我们使用Akka流Kafka来生成和消费消息和Strimzi Kafka集群。以下是相关版本： 重构消息发出后，消费者停止工作。我们在主题中确实有一些信息，但消费者只是在无休止地等待。 以下是日志片段： 还有一些要点： 架构注册表配置正确且良好（否则生产者将无法工作）。 主题（和组协调器）很好，我可以通过这样的普通消费者消费消息： 这就是代码卡住的地方——我使用阻塞调用获取2条消息（甚至无法获取1

我有一个kafka主题，有25个分区，集群已经运行了5个月。 根据我对给定主题的每个分区的理解，偏移量从0，1，2开始...(无界) 我看到log-end-offset值很高(现在- 我创建了一个新的消费群体，偏移设置为最早；因此，我预期该消费者组的客户端将从偏移量0开始的偏移量。 我用来创建一个偏移量为最早的新消费者组的命令： 我看到正在创建消费者组。我预计当前偏移量为0；然而，当我描述消费者组

如果我有一个RabbitMQ使用者，它可以批量检索100条消息，但它在将这些消息标记为已处理之前崩溃，那么这些消息会丢失吗？我希望队列中的每条消息至少被处理一次。对于在确认信息之前崩溃的消费者，建议采用什么方法来处理？ RabbitMQ是否以某种方式将它们放回队列中，或者我需要做些什么来实现它？