我这是校园双选会投的简历,然后就通知去面试。面试比较简单,没有笔试,先自我介绍,接着仔细的聊做过的项目,然后面试官介绍公司情况,让你提问题。主要问做过的项目细节,比如项目做的多久,为什么选择做这个项目,这个项目有什么困难,怎么解决的,采用什么技术以及采用的原因,哪一部分是你做的,通过细节了解你技术掌握的程度。我问了一下公司对这个岗位的要求,面试官比较有想法,谈了很多。 整个过程大约不到20分钟,面
我很难在Kafka主题的消费者中找到处理异常的简单模式。场景如下:在消费者中,我调用一个外部服务。如果服务不可用,我想重试几次,然后停止消费。 最简单的模式似乎是一种处理它的阻塞同步方式,在Java中如下所示: 但是,我觉得必须有一种更简单的方法(不使用第三方库),并且避免阻塞线程。 这似乎是我们想要的一种常见的东西,但我找不到一个简单的例子来说明这种模式。
我有一个(Posix)服务器,它充当许多客户端到另一个上游服务器的代理。消息通常从上游服务器向下流动,然后与之匹配,并被推出到对该流量感兴趣的客户端的某个子集(维护来自上游服务器的FIFO顺序)。目前,这个代理服务器是使用事件循环的单线程(例如-select、epoll等),但现在我想将它变成多线程,这样代理就可以更充分地利用整个机器并实现更高的吞吐量。 我的高级设计是拥有一个由N个工作线程组成的
使用指南 - 疑难问题 - 数据缺失或无数据问题 - 为什么推广报告只有消费点击而无浏览数据? 推广报告中的消费点击数据是账户粒度的,而统计报告是站点粒度的。 因此如果您有多个站点,需要将所有站点的浏览效果数据相加之后,与推广的消费点击数据作比较。 请检查您当前所选的站点是否是正在投放的推广站点。如果不是,请切换站点查看效果数据。
使用redis stream,用消费组,消费消息ack后仍然存在,看了下占用内存数量随着消息增长逐渐增加,ack后内存也不缩小,那这样长时间运行,消息占用的空间回越来越大,redis会回收内存或定期删除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. 为什么投递这个岗位?对中金所的了解?和专业不匹配怎么看?在上海工作
问题内容: 我正在尝试优化将大量结果插入远程mySQL数据库的过程。我为此使用简单的jdbc。 目前,我正在用PreparedStatement替换现有语句,并使用addBatch / executeBatch方法执行方法。有谁知道批量执行的限制?我可以在执行之前添加多少批次以确保过程不会失败?这些查询不是特殊查询,它们没有斑点或其他大字段。 问题答案: @BalusC碰到了头。如果您使用的是My
我正在使用confluent cloud,目前我希望防止在我的kafka主题中吸收具有坏模式的消息。为此,我正在使用confluent的模式管理功能,我希望验证消息是否与指定的模式不匹配,是否应该拒绝它。我可以在confluent本地制作,但在云上看不到拒绝。 < li >云目前是否支持模式验证? < li >如果不是,我们是否必须通过kafka streams实现它来验证我们自己的模式? < l
本文向大家介绍消费者驱动的契约(CDC)是什么?相关面试题,主要包含被问及消费者驱动的契约(CDC)是什么?时的应答技巧和注意事项,需要的朋友参考一下 这基本上是用于开发微服务的模式,以便它们可以被外部系统使用。当我们处理微服务时,有一个特定的生产者者构建它,并且有一个或多个使用微服务的消费者。 通常,生产者程序在 XML 文档中指定接口。但在消费者驱动的契约中,每个服务的消费者都传达了生产者期望
问题内容: 因此,我已经看到了许多在Go中实现一个消费者和许多生产者的方法-Go 并发中的经典fanIn函数。 我想要的是fanOut功能。它以一个通道作为参数,它从中读取一个值,并返回一个通道片,该通道将这个值的副本写入其中。 有没有正确/推荐的方法来实现这一目标? 问题答案: 您几乎描述了执行此操作的最佳方法,但这是执行此操作的一小段代码示例。 去游乐场:https : //play.gola
我有2个Kafka消费者共享相同的消费者组ID,但订阅不同的主题。它们中的每一个都只能从相应的主题中阅读。 当第一个使用者运行时,会从其订阅的主题中为其分配分区。当第二个使用者也运行时,使用者组会重新平衡(导致分配给第一个使用者的分区被撤销)。到目前为止,一切顺利。这与Kafka消费群体Id和消费者再平衡问题中的讨论一致。 但是,我开始在消费者1中看到TOPIC_AUTHORIZATION_FAI
问题内容: 我对于如何使用特定的生产者-消费者模式感到困惑,在该模式中,生产者和消费者都可以同时并独立地进行操作。 首先,考虑以下示例,该示例紧随docs中的示例: 关于此脚本,有一个更详细的细节:通过常规的for循环将项目同步放入队列。 我的目标是创建一个使用(或)和的脚本。两者都应安排为同时运行。没有一个消费者协程明确地与生产者绑定或链接。 我如何修改上面的程序,以便生产者是可以与消费者/工人
我想制作下面的数据发送架构。 生产商-- 消费者服务器可以关闭,因此我认为应该至少有两个消费者。是这样吗? 当一个数据流有两个使用者时,是否有任何方法可以处理每个使用者一半的数据?正如我所知,这是不可能的。如果每个消费者都使用相同的数据,那就是浪费时间和成本。因为我只为高可用性提供了两个消费者。(用于故障切换) 在web was体系结构中,ELB或L4可以通过负载平衡将一半数据发送到每个was服务
我有一个Kinesis生产者,它将单一类型的消息写入流。我想在多个完全不同的消费者应用程序中处理这个流。因此,给定主题/流的具有单个发布者的发布/订阅。我还想利用检查点来确保每个消费者处理写入流的每条消息。 最初,我对所有消费者和生产者使用相同的应用程序名称。但是,一旦我启动多个消费者,我就开始收到以下错误: 通用域名格式。amazonaws。服务。运动。模型InvalidArgumentExce