《中邮消费金融有限公司》专题

我有三根线。线程1(T1)是生成器，它生成数据。线程2和线程3(T2和T3)分别等待T1的数据在单独的循环中处理。我正在考虑在线程之间共享BlockingQueue,并通过调用“Take”让T2和T3等待。

我有一个Kafka流应用程序，它从几个主题中获取数据，并将数据加入另一个主题。 Kafka配置： 注意：我在运行Kafka Brokers的机器上运行Kafka Streams应用程序。 每小时消耗/产生数百万条记录。每当我让Kafka经纪人倒下时，都会进入再平衡阶段，再平衡大约需要30分钟，有时甚至更长时间。 有人知道如何解决Kafka消费者的再平衡问题吗？而且，很多时候，它在重新平衡时抛出异常

我的应用程序由一个带有POST方法的REST控制器组成，用于提交我必须使用生产者发送到主题的数据。 这是控制器 使用Spring-Cloud-Stream版本 从3.1版开始，和注释被弃用，所以我尝试切换到新的方式来设置生产者，我就是这样工作的 最后在应用程序中。yaml我有这个 现在的问题是，当我启动应用程序时，方法被无限调用（我在主题中看到消息）。然后使用供应商似乎我被迫在供应商内部定义消息数

我们正在运行活动 MQ 5.6.0。在我们的测试环境中，我们有 3 个代理在静态网络中运行。下面是当前方案。我们有6个消费者随机连接到3个经纪人。一个经纪人有3个消费者，第二个有2个，第三个有1个。当我们向队列堆积消息时，我们看到消息积压在第三个代理上，有 1 个使用者，另外两个代理没有获得任何积压，其余 5 个使用者处于空闲状态。 在下面，您将找到我们所有一个代理（dev.queue01）的配置

我的问题是关于Kafka在爪哇的消费者 > 已启动Kafka服务器 创建的主题 创作者 创建的消费者 我在终端中做的所有这些事情，工作正常，能够在消费者处正确接收日志。运行下面的消费者（在Java），但没有收到任何记录。它继续汇集在 也没有收到任何记录。 下面给出的我的 java 消费者代码 请告诉我在java消费者类中接收消息，我在配置中做错了什么吗？属性中的“group.id”是怎么回事？ 下

我正在尝试使用NodeJS从远程机器连接到远程Apache Kafka服务器。我无法从nodejs代码中生成所需的kafka主题的消息。我也无法消费任何数据从主题以及。 我使用的是Apache-kafka版本2.122.2.1和Java8。我也在使用节点版本8.11.0。我还启动了zookeeper服务器和kafka服务器。我在ubuntu机器上本地创建了一个主题和一个生产者和消费者，以检查apa

最近，我们与Kafka消费者和生产商之间出现了一些性能问题。我们在scala中使用Kafka Java API。打开和关闭消费者和生产者对象的良好做法是什么？我认为这是一个非常开放的问题，正确的答案总是，但我正在尝试对此进行推理。 消费者可以长时间运行连接并保持开放吗？ 当我们完成信息生成时，生产者是否应该关闭？

我有一个处于RPC模式的消费者（RabbitListner），我想知道是否有可能引发发布者可以处理的异常。 为了更清楚地说明我的情况如下： 发布者以RPC模式发送消息 消费者收到消息，检查消息的有效性，如果由于缺少参数，消息无法计数，那么我想抛出异常。异常可以是特定的业务异常，也可以是特定的AmqpException，但我希望发布者可以在未进入超时状态时处理该异常 我尝试使用AmqpRejectA

那么我如何确保我的队列中只有一个消费者呢？

我成功地建立了一个话题交换，并且能够同时向几个消费者传递消息。 我还想向竞争对手传递信息，并继续使用主题交换。我了解到，使用相同的队列名称可以让消费者竞争消息。然而，我可能弄错了，因为我无法使它工作。 为同一主题的多个侦听器设置： < li >申报话题交流 < li >对于每个侦听器，用自动生成的名称声明一个新队列 < li >用给定的主题路由关键字将此队列绑定到上面的交换 如何将相互竞争的消费者

我正在处理一个kafka用例，在这个用例中，我需要在生产者和消费者端具有事务性语义...我可以使用kafka transaction API 0.11将事务性消息发布到kafka集群，但在消费者端，我面临着一个问题...我在属性文件中设置了但我不能使用它...我可以看到消息被使用但这不是希望的... 生产者代码 ProducerTX.Properties 消费者 感谢你的帮助..谢谢

说明 此协议用于消费完成后发送消费完成/评价提醒消息，引导客人进入评价 需要将"提醒消息->消费完成/评价提醒"启用 请求地址 http://api.dc78.cn/Api/cash_complete 请求方式 GET 请求参数 参数 参数名称 必填 描述 范例 mbno 卡号 输入或扫码 id 会员卡id id和mbno两个可选其中之一 bzid 消费单编号 必须唯一，用于跟踪客人评价 返回 {

此协议用于消费完成后发送消费完成/评价提醒消息，引导客人进入评价 需要将"提醒消息->评价提醒"启用 请求参数说明 参数 描述 必填 示例值 类型 最大长度 action 接口参数组 是 object └action 需要调用的接口名称 是 cash_complete string get GET参数组，本组参数需要参与签名 是 object └mbno 会员卡号（id和mbno两个可选其中之一）

1.jvm内存划分 2.new创建的对象一定在java堆吗，局部变量是基本类型创建在哪，如果基本类型是成员变量呢 3.jvm堆内存详细说说，为什么要这么划分，用的垃圾回收算法 4. 什么时候会发生full gc 5.full gc对程序的影响 6.怎么解决full gc 7.线上系统发生了full gc我应该怎么快速解决定位 8.redis主要解决什么问题 9.redis单机qps一般多少 10.

拿offer了，7.5面试，7.12下offer Base是福州（俺是福州人，兴业证券、银行也是福州这边发家的） 面试平台是腾讯会议，35min左右，无手写代码，大概4～5个面试官，听后面介绍是来自不同部门，有金融科技部也有信息技术部。 整体面试有点迷哈哈哈，我投的是纯前端方向的JD，但是面试完全不涉及 html、js、css 知识。兴业证券的信息比较少，来贡献一个面经，凭记忆回忆一下内容： 自我