回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于Kafka Streams的问题，更具体地说，面试官想知道为什么/什么时候你会使用Kafka Streams DSL而不是普通的Kafka Consumer API来读取和处理消息流
浏览 2提问于2020-09-13得票数 3
在SPEL表达式下面试过，但无法工作。需要帮助！@KafkaListener(topics = "#{Arrays.asList(${kafka.topic.helloworld}.split(',')).stream().map(p -> p+envSuffix
浏览 1修改于2018-03-12得票数 2
回答已采纳
1回答
我正在从下面试用nxlog kafka out模块。我收到以下错误消息
ERROR Failed to load module from /usr/local/libexec/nxlog/modules/output/om_kafka.so, /usr/local/libexec/nxlog/modules/output/om_kafka.so: undefined symbol: r
浏览 4修改于2015-02-19得票数 1
回答已采纳
1)第一次迭代：Kafka本身具有流媒体、负载均衡和容错能力。在这种情况下，在考虑Kafka集群时，应该在开始时描述broker计数和分区。它本身并不是扩张的东西。这个问题的重点是负载均衡器看起来仍然需要，尽管Kafka是如此强大的候选者。
我的第二种方法类似于下面的模式。(在此期间，我在这次面试之前遇到过一些面试官，他们准确地将负载均衡器命名为“过时的技术”，我被评判为非常残酷，因为我建议使用负载均衡器。)如果你是一位Kafka
浏览 34提问于2020-02-06得票数 2
回答已采纳
火花突然开始接收到1500万到2000万条信息，用了5-6分钟的时间来处理，时间间隔为60秒。我已经配置了"spark.streaming.concurrentJobs=4"。当我开始接收1500万到2000万条消息时，处理这些消息的时间大约是5-6分钟，批处理间隔为60 Sec。当我检查我的HDFS目录时，我看到为每60 Sec创建的文件包含50个部分文件，在这里我一点也不困惑，我的批处理在5-6分钟内得到处理，然后它如何每1分钟在HDFS上写入文件&每批只调用一次'saveAsTextFile为了处
浏览 2修改于2016-12-16得票数 6
在经历了至少5-6小时的挣扎之后。我无法理解如何使用HTTP向Kafka服务器发送数据。
另外，有什么好的现实生活的例子出现在网站上，显示了卡夫卡集群的详细配置，将真正有助于初学者喜欢我。
浏览 3提问于2016-01-14得票数 1
回答已采纳
在一次编码面试中，你会如何识别这一点？你会画出所有的调用(即使其中的一些调用在O(2^n)复杂的蛮力解决方案中达到5-6级)吗？但在其他情况下，比如背包问题，我仍然无法思考如何在面试时使用回忆录。有没有快速检查重叠的方法？
我希望我的问题有意义。如果有人能给我一个好的资源，或者给我线索去寻找，我会非常感激的。提前谢谢。
浏览 3提问于2020-07-23得票数 0
我从许多人那里听说，面试官问的问题如下：
我不确定答案，也没有找到任何解释。在实时场景中，我从来没有机会在5-6以上的条件下筑巢。
浏览 3提问于2015-03-20得票数 0
6回答
我不想花太多时间进行培训，因为人们通常会在5-6个月后离职。(我们基本上是一个初创公司，公司里大约有8-9个人)。谢谢!
浏览 2修改于2013-07-30得票数 3
回答已采纳
我有一个火花应用程序，当它收到有关某个主题的kafka消息时，它应该运行。
我不会收到超过5-6条信息，所以我不想采取火花流的方法。
浏览 0修改于2016-09-13得票数 2
回答已采纳
我第一次在一个spring引导应用程序中构建了一个kafka消费者，所以请用参考资料或示例代码片段来指导我。我的要求如下：
应用程序应该有5-6个使用者，即线程->中的每个使用者一个，我可以使用@KafkaListener注释中的并发属性来设置它。我必须在kafka使用者启动之前创建一些对象来处理消息，并且每个线程应该有一个新的对象，因为这些对象在db ->中执行不同的写操作--请建议我如何通过在@KafkaListener中设置并发属性来实现这一点
浏览 14提问于2022-06-06得票数 0
2回答
所有呼叫都是阻塞和耗时的(假设avg响应时间为5-6分钟)。a)分阶段移动： - In this module provide an api to push events to kafka, anothermodule will in-turn process the request and push the response back - monolith fornow will call above mentioned api to push eve
浏览 5提问于2017-07-05得票数 1
3回答
我参加了一次面试，他给了我以下的情景。如果我能得到提示，因为我不能回答问题。
假设有一个应用程序，弹出窗口一直在出现。现在不是时候，只是随机的。你永远不知道他们什么时候会来。怎么处理呢？假设我在应用程序中有5-6页。在所有页面中，我们都有特定的文本字段。在第1页和第5页中，有一个对象是文本框。我看到，无论采用什么标识方法(css、xpath、id等)，值都是相同的。那是重复的。
浏览 1修改于2014-05-28得票数 0
回答已采纳
但5-6秒后就会传到经纪人那里。这里的负载不多，还需要6秒。我该如何提高表现。我的应用程序从上游接收数据并发布到kafka主题1。从这个kafka topic1，另一个应用程序使用和聚合基于键的数据，并发布到另一个kafka主题2。
浏览 0修改于2019-02-17得票数 0
我们是挑剔的谁，我们雇用，并有很好的保留率(大多数的发展中国家已经在这里平均5-6年)。技术电话采访-开发商60分钟的采访虽然这个过程很有效，但是我们在面试上花了太多的时间。我们收到1000份简历500通过在线考试10现场通过并被录用
正如你所看到的，我们需要在早期的过程中更好地淘汰候选人。以下是基于一些答复的更多有关这一过程的
浏览 0修改于2016-12-20得票数 17
range weather flag calculation 5-6 good n 14 5-6 worse y 5 输出如下： range weather flag calculation 0-5 worse n null 0-5 worse y
浏览 11提问于2020-01-13得票数 1
回答已采纳
上下文：微服务1:安排面试的后端服务。// QuestionBank :包含问题的表，面试官可以选择。
/
浏览 0修改于2018-05-13得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号