《中银消费金融面经》专题

D： \软件\Kafka\Kafka2.10-0.10.0.1\bin\windows 我使用上面的命令来消费消息，有什么我错过的吗？帮助我： 这个 那些是生产者和消费者......

我正在使用这个库来实现节点kafka与消费者暂停和恢复方法来处理背压。我已经创建了一个小演示，我可以在其中和，但问题是在后它停止了消费消息。 这是我的代码。 任何人都可以帮助我，我在恢复消费者时做错了什么？当我启动使用者时，它只接收一条消息，并且在恢复后仍然不消耗任何其他消息。

单选+多选+判断+一道sql+一道编程 数据库 加密算法 tomcat三大组件 中央银行 线性结构 operator new() 七层模型 金融知识（瞎猜）

考试时长：90min 60分钟答题和30分钟性格测试 答题部分（总共100分） 60分的计算机基础，有单选10个，多选10个，判断10个 数据库、计算机网络、操作系统、数据结构都有 20分的金融知识，10个单选 这部分非专业的确实只能靠蒙 20分的编程。纯编程题一道和SQL一道 没有代码编辑器，只有文本框，无语。 第一道编程题考的是用户邮箱过滤，第二道是对几个表进行查询和筛选。 个人感觉总的来说，

1、做个自我介绍 2、HashMap HashMap底层数据结构是什么？ HashMap中链表和红黑树的查询操作时间复杂度是多少？ HashMap是线程安全的吗？ HashTable和concurrentHashMap都是怎么实现线程安全的？ 3、线程池 线程池的参数有哪些？ 说一说线程池的组成？ 核心线程数一般是多少？ 线程池的任务调度是怎样的？ 4、MySQL 说一说索引的底层数据结构，有哪些

Q： 1.自我介绍 2.你了解到的产品经理完整的工作流程，详细说一下 3.你做产品经理的交付物是什么？ 4.数据运营具体是从事什么工作？ 5.你有了解华泰证券吗？ 6.你自己有使用过金融产品？从产品经理角度怎么看？有什么竞品？ 7.看过哪些产品经理的书？现在还在看哪些书？ 8.做产品经理的话，做数据分析你具体看哪些数据指标？看的周期是多久？ 9.之前社群运营的工作具体有哪些，指标提升了多少？ 10

主要内容：1 start启动服务定时锁定消息队列,1.2 lockAll锁定所有消息队列,2 submitConsumeRequest提交消费请求,3 ConsumeRequest执行消费任务,3.1 tryLockLaterAndReconsume尝试延迟加锁并重新消费,3.2 takeMessages拉取消息,4 processConsumeResult处理消费结果,4.1 commit提交消息,4.2 checkReconsumeTimes检查重试次数,,,基于RocketMQ relea

主要内容：1 start启动服务定时清理过期消息,1.1 cleanExpireMsg清理过期消息,1.2cleanExpiredMsg清理过期消息,2 submitConsumeRequest提交消费请求,2.2 submitConsumeRequestLater延迟提交,2.2 consumeMessageBatchMaxSize和pullBatchSize,3 ConsumeRequest执行消费任务,,,,基于RocketMQ release-4.9.3，深入的介绍了ConsumeMes

我将python kafka consumer的< code>auto_commit设置为< code>False，我正在手动提交消息。然而，重启后，消费者再次消费来自每个分区的最后一条消息。只有最后一个，不能再多。 这就是所展示的： 不知道为什么会显示滞后，whu当前偏移设置为最后一条消息而不是下一条？当我提交偏移量3时，当前偏移量不应该移动到4吗？ 我提交我使用的每条消息，但是在重启时，它总是

电话面，时长大约30分钟。没问项目，直接八股 1.JAVA线程的状态？是如何转换的？ 2.WAITING和BLOCKED区别？ 会不会占用时间片？（不知道） 3.线程池的参数有哪些？ 4.核心线程数和最大线程数，阻塞队列的长度如何设置？（阻塞队列的长度不知道） 5.事务是什么？Mysql如何实现事务？ 6.具体解释下一致性如何保证？ 7.undo log原理讲一下 8. Leetcode1143-

rpc是自己做的么，为什么要用rpc，不用http 类传输为什么要转为字节流 怎么设计MySQL的表的 设计表的三范式 redis基础数据结构 Redis为什么快 Redis存储了什么东西 kafka怎么用的 kafka数据结构 kafka怎么顺序读取数据 算法题：中等难度链表题（挂）#软件开发2024笔面经##金三银四，你有感觉到吗##春招已经启动啦 硬件uu开始投了吗？##你收到了团子的OC了

当一个组中只有一个消费者，并且认为消费者无法在session.time.out内进行轮询时，将触发重新平衡，但是在这种情况下，组中只有一个消费者，现在假设session.time.out是30秒和消费者民意调查后50秒组协调员将识别消费者后50秒，并允许它提交偏移或协调员将断开消费者和没有偏移得到提交，并将重新平衡消费者与新的消费者标识？如果上次提交的偏移量是345678，在下一次轮询中，它处理了

一面1. 项目问题+数据表现+周转周期 2. ai 云服务 知识图谱的了解 3. ai的未来发展会是什么样子 4. 如果自己设计一款产品做什么 怎么做 5. 市面上有没有类似的 有什么优势 6. 对产品工作的理解 能力维度 7. 对联易融的了解 8. 兴趣爱好#联易融#

- golang 协程交替打印数字 - 删除链表重复元素，重复元素不保留 其他就是一些项目相关的问题。 总体做的事情是配合度小满的私有云改造，，工作强度大概是10-9-5，周末可能需要加班 #面经#

一面 1h40min 1. ioc 2. aop aop和oop 3.抽象类和接口 4. ==和equals() 5. final关键字 6. 深拷贝浅拷贝 7. 工厂模式和单例模式，举例，适用场景，作用 8. mybatis ${}和#{}的区别 9. MQ事务消息 10. aftersync和aftercommit MySQL半同步复制 11. 数据库事务特性 隔离性 12. 排他锁 意向排他